X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Ftopology-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmd%2Fcontroller%2Ftopology%2Fmanager%2FFlowCapableTopologyProvider.xtend;h=73e03d1e7d208287c1bed8505f889fbe470c8fa8;hp=036fe733aa80b56ac7cc2302d9a26cab0d2703ac;hb=00518e6fec2fee03d7ff373d977af328d701ad1f;hpb=31a2298fc02482baae6507596ccc8c842d3e3dfb diff --git a/opendaylight/md-sal/topology-manager/src/main/java/org/opendaylight/md/controller/topology/manager/FlowCapableTopologyProvider.xtend b/opendaylight/md-sal/topology-manager/src/main/java/org/opendaylight/md/controller/topology/manager/FlowCapableTopologyProvider.xtend index 036fe733aa..73e03d1e7d 100644 --- a/opendaylight/md-sal/topology-manager/src/main/java/org/opendaylight/md/controller/topology/manager/FlowCapableTopologyProvider.xtend +++ b/opendaylight/md-sal/topology-manager/src/main/java/org/opendaylight/md/controller/topology/manager/FlowCapableTopologyProvider.xtend @@ -14,6 +14,7 @@ import org.opendaylight.yangtools.yang.binding.NotificationListener import org.slf4j.LoggerFactory import org.opendaylight.controller.sal.binding.api.AbstractBindingAwareProvider import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext +import org.osgi.framework.BundleContext; class FlowCapableTopologyProvider extends AbstractBindingAwareProvider implements AutoCloseable { @@ -35,7 +36,11 @@ class FlowCapableTopologyProvider extends AbstractBindingAwareProvider implement LOG.info("FlowCapableTopologyProvider stopped."); listenerRegistration?.close(); } - + + /** + * Gets called on start of a bundle. + * @param session + */ override onSessionInitiated(ProviderContext session) { dataService = session.getSALService(DataProviderService) notificationService = session.getSALService(NotificationProviderService) @@ -43,6 +48,14 @@ class FlowCapableTopologyProvider extends AbstractBindingAwareProvider implement exporter.start(); listenerRegistration = notificationService.registerNotificationListener(exporter); } + + /** + * Gets called during stop bundle + * @param context The execution context of the bundle being stopped. + */ + override stopImpl(BundleContext context) { + close(); + } }