X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fstatistics-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fstatistics%2Fmanager%2FStatisticsProvider.java;h=8c9b60e43f0b7dc373b3365039ab950f86df6bfc;hp=d8bea7c63a4606fffaed51a9dce5fe889dca2d36;hb=17d82f582a6bc13c78be3b19954ff8c021180e93;hpb=0b499893a981d06759738e81fa8cb6d098acda80 diff --git a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java index d8bea7c63a..8c9b60e43f 100644 --- a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java +++ b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java @@ -28,7 +28,6 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111. import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.OpendaylightPortStatisticsService; import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.OpendaylightQueueStatisticsService; import org.opendaylight.yangtools.concepts.ListenerRegistration; -import org.opendaylight.yangtools.concepts.Registration; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.opendaylight.yangtools.yang.binding.NotificationListener; import org.slf4j.Logger; @@ -66,7 +65,7 @@ public class StatisticsProvider implements AutoCloseable { private OpendaylightFlowTableStatisticsService flowTableStatsService; private OpendaylightQueueStatisticsService queueStatsService; - + private final StatisticsRequestScheduler srScheduler; public StatisticsProvider(final DataProviderService dataService) { @@ -76,7 +75,7 @@ public class StatisticsProvider implements AutoCloseable { private final StatisticsListener updateCommiter = new StatisticsListener(StatisticsProvider.this); - private Registration listenerRegistration; + private ListenerRegistration listenerRegistration; private ListenerRegistration flowCapableTrackerRegistration; @@ -90,7 +89,7 @@ public class StatisticsProvider implements AutoCloseable { flowTableStatsService = rpcRegistry.getRpcService(OpendaylightFlowTableStatisticsService.class); queueStatsService = rpcRegistry.getRpcService(OpendaylightQueueStatisticsService.class); this.srScheduler.start(); - + // Start receiving notifications this.listenerRegistration = nps.registerNotificationListener(this.updateCommiter);