opendaylight/md-sal/sal-zeromq-connector/src/main/java/org/opendaylight/controller/sal/connector/zeromq/Activator.java

   1 package org.opendaylight.controller.sal.connector.zeromq;
   2
   3 import org.opendaylight.controller.sal.core.api.AbstractProvider;
   4 import org.opendaylight.controller.sal.core.api.Broker.ProviderSession;
   5 import org.osgi.framework.BundleContext;
   6
   7 public class Activator extends AbstractProvider {
   8
   9     ZeroMqRpcRouter router;
  10
  11     @Override
  12     public void onSessionInitiated(ProviderSession session) {
  13         router = ZeroMqRpcRouter.getInstance();
  14         router.setBrokerSession(session);
  15         router.start();
  16     }
  17
  18     @Override
  19     protected void stopImpl(BundleContext context) {
  20        router.stop();
  21     }
  22
  23 }