X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fnetconf-notifications-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fnetconf%2Fnotifications%2Fimpl%2Fosgi%2FActivator.java;h=bd2d5d6b7985bf4724e0f8da453cedb51867ac2e;hb=refs%2Fchanges%2F13%2F23413%2F26;hp=a0a0dfcb8f5e506071daa1b5b894aa0074f556ca;hpb=38d476e7161a4dd6dbaf68aa90a64cb466e62628;p=controller.git diff --git a/opendaylight/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/controller/netconf/notifications/impl/osgi/Activator.java b/opendaylight/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/controller/netconf/notifications/impl/osgi/Activator.java index a0a0dfcb8f..bd2d5d6b79 100644 --- a/opendaylight/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/controller/netconf/notifications/impl/osgi/Activator.java +++ b/opendaylight/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/controller/netconf/notifications/impl/osgi/Activator.java @@ -8,14 +8,13 @@ package org.opendaylight.controller.netconf.notifications.impl.osgi; -import com.google.common.base.Optional; import com.google.common.collect.Sets; -import java.util.Collection; import java.util.Collections; import java.util.Dictionary; import java.util.Hashtable; import java.util.Set; -import org.opendaylight.controller.netconf.api.Capability; +import org.opendaylight.controller.config.util.capability.BasicCapability; +import org.opendaylight.controller.config.util.capability.Capability; import org.opendaylight.controller.netconf.api.monitoring.CapabilityListener; import org.opendaylight.controller.netconf.api.util.NetconfConstants; import org.opendaylight.controller.netconf.mapping.api.NetconfOperation; @@ -29,9 +28,13 @@ import org.opendaylight.controller.netconf.notifications.impl.ops.Get; import org.osgi.framework.BundleActivator; import org.osgi.framework.BundleContext; import org.osgi.framework.ServiceRegistration; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class Activator implements BundleActivator { + private static final Logger LOG = LoggerFactory.getLogger(Activator.class); + private ServiceRegistration netconfNotificationCollectorServiceRegistration; private ServiceRegistration operationaServiceRegistration; private NetconfNotificationManager netconfNotificationManager; @@ -43,7 +46,7 @@ public class Activator implements BundleActivator { final NetconfOperationServiceFactory netconfOperationServiceFactory = new NetconfOperationServiceFactory() { - private final Set capabilities = Collections.singleton(new NotificationsCapability()); + private final Set capabilities = Collections.singleton(new BasicCapability(NetconfNotification.NOTIFICATION_NAMESPACE)); @Override public Set getCapabilities() { @@ -52,11 +55,11 @@ public class Activator implements BundleActivator { @Override public AutoCloseable registerCapabilityListener(final CapabilityListener listener) { - listener.onCapabilitiesAdded(capabilities); + listener.onCapabilitiesChanged(capabilities, Collections.emptySet()); return new AutoCloseable() { @Override public void close() { - listener.onCapabilitiesRemoved(capabilities); + listener.onCapabilitiesChanged(Collections.emptySet(), capabilities); } }; } @@ -67,7 +70,6 @@ public class Activator implements BundleActivator { private final CreateSubscription createSubscription = new CreateSubscription(netconfSessionIdForReporting, netconfNotificationManager); - @Override public Set getNetconfOperations() { return Sets.newHashSet( @@ -86,7 +88,6 @@ public class Activator implements BundleActivator { final Dictionary properties = new Hashtable<>(); properties.put(NetconfConstants.SERVICE_NAME, NetconfConstants.NETCONF_MONITORING); operationaServiceRegistration = context.registerService(NetconfOperationServiceFactory.class, netconfOperationServiceFactory, properties); - } @Override @@ -103,36 +104,4 @@ public class Activator implements BundleActivator { operationaServiceRegistration = null; } } - - private class NotificationsCapability implements Capability { - @Override - public String getCapabilityUri() { - return NetconfNotification.NOTIFICATION_NAMESPACE; - } - - @Override - public Optional getModuleNamespace() { - return Optional.absent(); - } - - @Override - public Optional getModuleName() { - return Optional.absent(); - } - - @Override - public Optional getRevision() { - return Optional.absent(); - } - - @Override - public Optional getCapabilitySchema() { - return Optional.absent(); - } - - @Override - public Collection getLocation() { - return Collections.emptyList(); - } - } }