opendaylight/md-sal/sal-remoterpc-connector/implementation/src/main/java/org/opendaylight/controller/config/yang/md/sal/remote/rpc/ZeroMQServerModule.java

   1 /**
   2 * Generated file
   3
   4 * Generated from: yang module name: odl-sal-dom-rpc-remote-cfg  yang module local name: remote-zeromq-rpc-server
   5 * Generated by: org.opendaylight.controller.config.yangjmxgenerator.plugin.JMXGenerator
   6 * Generated at: Thu Dec 05 14:25:21 CET 2013
   7 *
   8 * Do not modify this file unless it is present under src/main directory
   9 */
  10 package org.opendaylight.controller.config.yang.md.sal.remote.rpc;
  11
  12 import org.opendaylight.controller.sal.connector.remoterpc.*;
  13 import org.opendaylight.controller.sal.core.api.Broker;
  14 import org.osgi.framework.BundleContext;
  15
  16 /**
  17 *
  18 */
  19 public final class ZeroMQServerModule extends org.opendaylight.controller.config.yang.md.sal.remote.rpc.AbstractZeroMQServerModule
  20  {
  21
  22     private static final Integer ZEROMQ_ROUTER_PORT = 5554;
  23     private BundleContext bundleContext;
  24
  25     public ZeroMQServerModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
  26         super(identifier, dependencyResolver);
  27     }
  28
  29     public ZeroMQServerModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver,
  30             ZeroMQServerModule oldModule, java.lang.AutoCloseable oldInstance) {
  31
  32         super(identifier, dependencyResolver, oldModule, oldInstance);
  33     }
  34
  35     @Override
  36     protected void customValidation(){
  37         // Add custom validation for module attributes here.
  38     }
  39
  40     @Override
  41     public java.lang.AutoCloseable createInstance() {
  42
  43         Broker broker = getDomBrokerDependency();
  44
  45
  46
  47         final int port = getPort() != null ? getPort() : ZEROMQ_ROUTER_PORT;
  48
  49         ServerImpl serverImpl = new ServerImpl(port);
  50
  51         ClientImpl clientImpl = new ClientImpl();
  52
  53         RoutingTableProvider provider = new RoutingTableProvider(bundleContext,serverImpl);
  54
  55
  56         RemoteRpcProvider facade = new RemoteRpcProvider(serverImpl, clientImpl);
  57
  58         facade.setRoutingTableProvider(provider );
  59
  60         broker.registerProvider(facade, bundleContext);
  61         return facade;
  62     }
  63
  64     public void setBundleContext(BundleContext bundleContext) {
  65         this.bundleContext = bundleContext;
  66     }
  67 }