X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fnetconf-notifications-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fnotifications%2Fimpl%2Fosgi%2FActivator.java;h=967bd08914e17734628387badc80fe921e770be9;hb=4597743d04e91970310a3214870005d7ec59c30d;hp=146f5e7116aa3f56c2277b687d495696ef658360;hpb=c8fa0b47c985456271ee71ed18f2d25e93225cad;p=netconf.git diff --git a/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/netconf/notifications/impl/osgi/Activator.java b/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/netconf/notifications/impl/osgi/Activator.java index 146f5e7116..967bd08914 100644 --- a/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/netconf/notifications/impl/osgi/Activator.java +++ b/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/netconf/notifications/impl/osgi/Activator.java @@ -14,8 +14,8 @@ import java.util.Collections; import java.util.Dictionary; import java.util.Hashtable; import java.util.Set; -import org.opendaylight.controller.config.util.capability.BasicCapability; -import org.opendaylight.controller.config.util.capability.Capability; +import org.opendaylight.netconf.api.capability.BasicCapability; +import org.opendaylight.netconf.api.capability.Capability; import org.opendaylight.netconf.api.monitoring.CapabilityListener; import org.opendaylight.netconf.api.util.NetconfConstants; import org.opendaylight.netconf.mapping.api.NetconfOperation; @@ -41,18 +41,18 @@ public class Activator implements BundleActivator { private NetconfNotificationManager netconfNotificationManager; @Override - public void start(final BundleContext context) throws Exception { + public void start(final BundleContext context) { netconfNotificationManager = new NetconfNotificationManager(); // Add properties to autowire with netconf-impl instance for cfg subsystem final Dictionary props = new Hashtable<>(); props.put(NetconfConstants.SERVICE_NAME, NetconfConstants.NETCONF_NOTIFICATION); netconfNotificationCollectorServiceRegistration = context.registerService(NetconfNotificationCollector.class, - netconfNotificationManager, new Hashtable()); + netconfNotificationManager, new Hashtable<>()); final NetconfOperationServiceFactory netconfOperationServiceFactory = new NetconfOperationServiceFactory() { private final Set capabilities = - Collections.singleton(new BasicCapability(NetconfNotification.NOTIFICATION_NAMESPACE)); + Collections.singleton(new BasicCapability(NetconfNotification.NOTIFICATION_NAMESPACE)); @Override public Set getCapabilities() { @@ -61,13 +61,8 @@ public class Activator implements BundleActivator { @Override public AutoCloseable registerCapabilityListener(final CapabilityListener listener) { - listener.onCapabilitiesChanged(capabilities, Collections.emptySet()); - return new AutoCloseable() { - @Override - public void close() { - listener.onCapabilitiesChanged(Collections.emptySet(), capabilities); - } - }; + listener.onCapabilitiesChanged(capabilities, Collections.emptySet()); + return () -> listener.onCapabilitiesChanged(Collections.emptySet(), capabilities); } @Override @@ -79,7 +74,7 @@ public class Activator implements BundleActivator { @Override public Set getNetconfOperations() { - return Sets.newHashSet( + return Sets.newHashSet( new Get(netconfSessionIdForReporting, netconfNotificationManager), createSubscription); } @@ -99,7 +94,7 @@ public class Activator implements BundleActivator { } @Override - public void stop(final BundleContext context) throws Exception { + public void stop(final BundleContext context) { if (netconfNotificationCollectorServiceRegistration != null) { netconfNotificationCollectorServiceRegistration.unregister(); netconfNotificationCollectorServiceRegistration = null;