X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fimplementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fyang%2Fmd%2Fsal%2Fremote%2Frpc%2FZeroMQServerModule.java;h=e3ac9bab300b2ff3c0e0e0e04b3c10f27e5d28a7;hb=22000c97031a397b247a75ede2383f6ae792efc9;hp=f55566acc37ca9c4eac03ab87642c77db28a1f69;hpb=7dd4359be20305d236a08c6b2db0c001cf7d7754;p=controller.git diff --git a/opendaylight/md-sal/sal-remoterpc-connector/implementation/src/main/java/org/opendaylight/controller/config/yang/md/sal/remote/rpc/ZeroMQServerModule.java b/opendaylight/md-sal/sal-remoterpc-connector/implementation/src/main/java/org/opendaylight/controller/config/yang/md/sal/remote/rpc/ZeroMQServerModule.java index f55566acc3..e3ac9bab30 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/implementation/src/main/java/org/opendaylight/controller/config/yang/md/sal/remote/rpc/ZeroMQServerModule.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/implementation/src/main/java/org/opendaylight/controller/config/yang/md/sal/remote/rpc/ZeroMQServerModule.java @@ -7,7 +7,10 @@ */ package org.opendaylight.controller.config.yang.md.sal.remote.rpc; -import org.opendaylight.controller.sal.connector.remoterpc.*; +import org.opendaylight.controller.sal.connector.remoterpc.ClientImpl; +import org.opendaylight.controller.sal.connector.remoterpc.RemoteRpcProvider; +import org.opendaylight.controller.sal.connector.remoterpc.RoutingTableProvider; +import org.opendaylight.controller.sal.connector.remoterpc.ServerImpl; import org.opendaylight.controller.sal.core.api.Broker; import org.opendaylight.controller.sal.core.api.RpcProvisionRegistry; import org.osgi.framework.BundleContext; @@ -16,51 +19,51 @@ import org.osgi.framework.BundleContext; * */ public final class ZeroMQServerModule - extends org.opendaylight.controller.config.yang.md.sal.remote.rpc.AbstractZeroMQServerModule { +extends org.opendaylight.controller.config.yang.md.sal.remote.rpc.AbstractZeroMQServerModule { - private static final Integer ZEROMQ_ROUTER_PORT = 5554; - private BundleContext bundleContext; + private static final Integer ZEROMQ_ROUTER_PORT = 5554; + private BundleContext bundleContext; - public ZeroMQServerModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, - org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) { - super(identifier, dependencyResolver); - } + public ZeroMQServerModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, + final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) { + super(identifier, dependencyResolver); + } - public ZeroMQServerModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, - org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, - ZeroMQServerModule oldModule, java.lang.AutoCloseable oldInstance) { + public ZeroMQServerModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, + final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, + final ZeroMQServerModule oldModule, final java.lang.AutoCloseable oldInstance) { - super(identifier, dependencyResolver, oldModule, oldInstance); - } + super(identifier, dependencyResolver, oldModule, oldInstance); + } - @Override - protected void customValidation() { - // Add custom validation for module attributes here. - } + @Override + protected void customValidation() { + // Add custom validation for module attributes here. + } - @Override - public java.lang.AutoCloseable createInstance() { + @Override + public java.lang.AutoCloseable createInstance() { - Broker broker = getDomBrokerDependency(); + Broker broker = getDomBrokerDependency(); - final int port = getPort() != null ? getPort() : ZEROMQ_ROUTER_PORT; + final int port = getPort() != null ? getPort() : ZEROMQ_ROUTER_PORT; - ServerImpl serverImpl = new ServerImpl(port); + ServerImpl serverImpl = new ServerImpl(port); - ClientImpl clientImpl = new ClientImpl(); + ClientImpl clientImpl = new ClientImpl(); - RoutingTableProvider provider = new RoutingTableProvider(bundleContext);//,serverImpl); + RoutingTableProvider provider = new RoutingTableProvider(bundleContext);//,serverImpl); - RemoteRpcProvider facade = new RemoteRpcProvider(serverImpl, clientImpl); - facade.setRoutingTableProvider(provider); - facade.setContext(bundleContext); - facade.setRpcProvisionRegistry((RpcProvisionRegistry) broker); + RemoteRpcProvider facade = new RemoteRpcProvider(serverImpl, clientImpl); + facade.setRoutingTableProvider(provider); + facade.setContext(bundleContext); + facade.setRpcProvisionRegistry((RpcProvisionRegistry) broker); - broker.registerProvider(facade, bundleContext); - return facade; - } + broker.registerProvider(facade, bundleContext); + return facade; + } - public void setBundleContext(BundleContext bundleContext) { - this.bundleContext = bundleContext; - } + public void setBundleContext(final BundleContext bundleContext) { + this.bundleContext = bundleContext; + } }