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.Client;
  13 import org.opendaylight.controller.sal.connector.remoterpc.RemoteRpcProvider;
  14 import org.opendaylight.controller.sal.connector.remoterpc.RoutingTableProvider;
  15 import org.opendaylight.controller.sal.connector.remoterpc.ServerImpl;
  16 import org.opendaylight.controller.sal.core.api.Broker;
  17 import org.osgi.framework.BundleContext;
  18
  19 /**
  20 *
  21 */
  22 public final class ZeroMQServerModule extends org.opendaylight.controller.config.yang.md.sal.remote.rpc.AbstractZeroMQServerModule
  23  {
  24
  25     private static final Integer ZEROMQ_ROUTER_PORT = 5554;
  26     private BundleContext bundleContext;
  27
  28     public ZeroMQServerModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
  29         super(identifier, dependencyResolver);
  30     }
  31
  32     public ZeroMQServerModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver,
  33             ZeroMQServerModule oldModule, java.lang.AutoCloseable oldInstance) {
  34
  35         super(identifier, dependencyResolver, oldModule, oldInstance);
  36     }
  37
  38     @Override
  39     protected void customValidation(){
  40         // Add custom validation for module attributes here.
  41     }
  42
  43     @Override
  44     public java.lang.AutoCloseable createInstance() {
  45
  46         Broker broker = getDomBrokerDependency();
  47         RoutingTableProvider provider = new RoutingTableProvider(bundleContext);
  48
  49
  50         final int port = getPort() != null ? getPort() : ZEROMQ_ROUTER_PORT;
  51
  52         ServerImpl serverImpl = new ServerImpl(port);
  53
  54         Client clientImpl = new Client();
  55         RemoteRpcProvider facade = new RemoteRpcProvider(serverImpl, clientImpl);
  56
  57         facade.setRoutingTableProvider(provider );
  58
  59         broker.registerProvider(facade, bundleContext);
  60         return facade;
  61     }
  62
  63     public void setBundleContext(BundleContext bundleContext) {
  64         this.bundleContext = bundleContext;
  65     }
  66 }