Remove unused routedRpcRegistration

[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / statistics / services / direct / OpendaylightDirectStatisticsServiceImpl.java

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/OpendaylightDirectStatisticsServiceImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/OpendaylightDirectStatisticsServiceImpl.java
index 8e2cea384a479b0d107f17380952cd87c9efc911..5b4ef7879ef0046e20b7bf93f767f3dea570ecfa 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/OpendaylightDirectStatisticsServiceImpl.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/OpendaylightDirectStatisticsServiceImpl.java
@@ -8,7 +8,7 @@
 
 package org.opendaylight.openflowplugin.impl.statistics.services.direct;
 
-import java.util.concurrent.Future;
+import com.google.common.util.concurrent.ListenableFuture;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetFlowStatisticsInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetFlowStatisticsOutput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetGroupStatisticsInput;
@@ -21,7 +21,7 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetQueueStatisticsOutput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.OpendaylightDirectStatisticsService;
 import org.opendaylight.yangtools.yang.binding.DataObject;
-import org.opendaylight.yangtools.yang.common.RpcError;
+import org.opendaylight.yangtools.yang.common.ErrorType;
 import org.opendaylight.yangtools.yang.common.RpcResult;
 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
 
@@ -43,7 +43,7 @@ public class OpendaylightDirectStatisticsServiceImpl implements OpendaylightDire
 
     @Override
     @SuppressWarnings("unchecked")
-    public Future<RpcResult<GetGroupStatisticsOutput>> getGroupStatistics(GetGroupStatisticsInput input) {
+    public ListenableFuture<RpcResult<GetGroupStatisticsOutput>> getGroupStatistics(GetGroupStatisticsInput input) {
         return provider.lookup(AbstractGroupDirectStatisticsService.class)
                 .map(service -> service.handleAndReply(input))
                 .orElse(missingImplementation(AbstractGroupDirectStatisticsService.class));
@@ -51,7 +51,7 @@ public class OpendaylightDirectStatisticsServiceImpl implements OpendaylightDire
 
     @Override
     @SuppressWarnings("unchecked")
-    public Future<RpcResult<GetQueueStatisticsOutput>> getQueueStatistics(GetQueueStatisticsInput input) {
+    public ListenableFuture<RpcResult<GetQueueStatisticsOutput>> getQueueStatistics(GetQueueStatisticsInput input) {
         return provider.lookup(AbstractQueueDirectStatisticsService.class)
                 .map(service -> service.handleAndReply(input))
                 .orElse(missingImplementation(AbstractQueueDirectStatisticsService.class));
@@ -59,7 +59,7 @@ public class OpendaylightDirectStatisticsServiceImpl implements OpendaylightDire
 
     @Override
     @SuppressWarnings("unchecked")
-    public Future<RpcResult<GetFlowStatisticsOutput>> getFlowStatistics(GetFlowStatisticsInput input) {
+    public ListenableFuture<RpcResult<GetFlowStatisticsOutput>> getFlowStatistics(GetFlowStatisticsInput input) {
         return provider.lookup(AbstractFlowDirectStatisticsService.class)
                 .map(service -> service.handleAndReply(input))
                 .orElse(missingImplementation(AbstractFlowDirectStatisticsService.class));
@@ -67,7 +67,7 @@ public class OpendaylightDirectStatisticsServiceImpl implements OpendaylightDire
 
     @Override
     @SuppressWarnings("unchecked")
-    public Future<RpcResult<GetMeterStatisticsOutput>> getMeterStatistics(GetMeterStatisticsInput input) {
+    public ListenableFuture<RpcResult<GetMeterStatisticsOutput>> getMeterStatistics(GetMeterStatisticsInput input) {
         return provider.lookup(AbstractMeterDirectStatisticsService.class)
                 .map(service -> service.handleAndReply(input))
                 .orElse(missingImplementation(AbstractMeterDirectStatisticsService.class));
@@ -75,15 +75,16 @@ public class OpendaylightDirectStatisticsServiceImpl implements OpendaylightDire
 
     @Override
     @SuppressWarnings("unchecked")
-    public Future<RpcResult<GetNodeConnectorStatisticsOutput>> getNodeConnectorStatistics(GetNodeConnectorStatisticsInput input) {
+    public ListenableFuture<RpcResult<GetNodeConnectorStatisticsOutput>>
+            getNodeConnectorStatistics(GetNodeConnectorStatisticsInput input) {
         return provider.lookup(AbstractPortDirectStatisticsService.class)
                 .map(service -> service.handleAndReply(input))
                 .orElse(missingImplementation(AbstractPortDirectStatisticsService.class));
     }
 
-    private static <T extends DataObject> Future<RpcResult<T>> missingImplementation(Class service) {
+    private static <T extends DataObject> ListenableFuture<RpcResult<T>> missingImplementation(Class service) {
         return RpcResultBuilder.<T>failed().withError(
-                RpcError.ErrorType.APPLICATION,
+                ErrorType.APPLICATION,
                 String.format("No implementation found for direct statistics service %s.", service.getCanonicalName()))
                 .buildFuture();
     }