Remove unused routedRpcRegistration
[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / statistics / services / OpendaylightFlowStatisticsServiceImpl.java
index 79d621d9ede9d4fbb1e9df5f2ddf7161196b156b..f6f9878fae456d9c2236e314ece201d142a7e415 100644 (file)
@@ -1,4 +1,4 @@
-/**
+/*
  * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
  *
  * This program and the accompanying materials are made available under the
@@ -7,7 +7,7 @@
  */
 package org.opendaylight.openflowplugin.impl.statistics.services;
 
-import java.util.concurrent.Future;
+import com.google.common.util.concurrent.ListenableFuture;
 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
 import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
 import org.opendaylight.openflowplugin.api.openflow.device.TranslatorLibrary;
@@ -28,26 +28,27 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.G
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.OpendaylightFlowStatisticsService;
 import org.opendaylight.yangtools.yang.common.RpcResult;
 
-/**
- * @author joe
- */
-public class OpendaylightFlowStatisticsServiceImpl implements OpendaylightFlowStatisticsService, Delegator<OpendaylightFlowStatisticsService> {
+public class OpendaylightFlowStatisticsServiceImpl implements OpendaylightFlowStatisticsService,
+                                                              Delegator<OpendaylightFlowStatisticsService> {
 
     private final SingleLayerAggregateFlowMultipartService singleLayerService;
     private final MultiLayerAggregateFlowMultipartService multiLayerService;
     private OpendaylightFlowStatisticsService delegate;
 
     public static OpendaylightFlowStatisticsServiceImpl createWithOook(final RequestContextStack requestContextStack,
-                                                              final DeviceContext deviceContext, final ConvertorExecutor convertorExecutor) {
-        return new OpendaylightFlowStatisticsServiceImpl(requestContextStack, deviceContext, deviceContext.oook(), convertorExecutor);
+                                                                       final DeviceContext deviceContext,
+                                                                       final ConvertorExecutor convertorExecutor) {
+        return new OpendaylightFlowStatisticsServiceImpl(requestContextStack,
+                                                         deviceContext,
+                                                         deviceContext.oook(),
+                                                         convertorExecutor);
     }
 
     public OpendaylightFlowStatisticsServiceImpl(final RequestContextStack requestContextStack,
                                                  final DeviceContext deviceContext,
                                                  final TranslatorLibrary translatorLibrary,
                                                  final ConvertorExecutor convertorExecutor) {
-        singleLayerService = new SingleLayerAggregateFlowMultipartService(requestContextStack, deviceContext,
-            convertorExecutor);
+        singleLayerService = new SingleLayerAggregateFlowMultipartService(requestContextStack, deviceContext);
         multiLayerService = new MultiLayerAggregateFlowMultipartService(requestContextStack, deviceContext,
             convertorExecutor, translatorLibrary);
     }
@@ -58,12 +59,15 @@ public class OpendaylightFlowStatisticsServiceImpl implements OpendaylightFlowSt
     }
 
     /**
-     * @deprecated provided for Be-release as backward compatibility relic
+     * Get aggregate statistics.
+     *
+     * @deprecated provided for Be-release as backward compatibility relic.
      */
     @Override
     @Deprecated
-    public Future<RpcResult<GetAggregateFlowStatisticsFromFlowTableForAllFlowsOutput>> getAggregateFlowStatisticsFromFlowTableForAllFlows(
-            final GetAggregateFlowStatisticsFromFlowTableForAllFlowsInput input) {
+    public ListenableFuture<RpcResult<GetAggregateFlowStatisticsFromFlowTableForAllFlowsOutput>>
+        getAggregateFlowStatisticsFromFlowTableForAllFlows(
+                final GetAggregateFlowStatisticsFromFlowTableForAllFlowsInput input) {
         if (delegate != null) {
             return delegate.getAggregateFlowStatisticsFromFlowTableForAllFlows(input);
         } else {
@@ -72,19 +76,22 @@ public class OpendaylightFlowStatisticsServiceImpl implements OpendaylightFlowSt
     }
 
     @Override
-    public Future<RpcResult<GetAggregateFlowStatisticsFromFlowTableForGivenMatchOutput>> getAggregateFlowStatisticsFromFlowTableForGivenMatch(
-            final GetAggregateFlowStatisticsFromFlowTableForGivenMatchInput input) {
+    public ListenableFuture<RpcResult<GetAggregateFlowStatisticsFromFlowTableForGivenMatchOutput>>
+        getAggregateFlowStatisticsFromFlowTableForGivenMatch(
+                final GetAggregateFlowStatisticsFromFlowTableForGivenMatchInput input) {
         return singleLayerService.canUseSingleLayerSerialization()
             ? singleLayerService.handleAndReply(input)
             : multiLayerService.handleAndReply(input);
     }
 
     /**
-     * @deprecated provided for Be-release as backward compatibility relic
+     * Get flow statistics.
+     *
+     * @deprecated provided for Be-release as backward compatibility relic.
      */
     @Override
     @Deprecated
-    public Future<RpcResult<GetAllFlowStatisticsFromFlowTableOutput>> getAllFlowStatisticsFromFlowTable(
+    public ListenableFuture<RpcResult<GetAllFlowStatisticsFromFlowTableOutput>> getAllFlowStatisticsFromFlowTable(
             final GetAllFlowStatisticsFromFlowTableInput input) {
         if (delegate != null) {
             return delegate.getAllFlowStatisticsFromFlowTable(input);
@@ -94,12 +101,14 @@ public class OpendaylightFlowStatisticsServiceImpl implements OpendaylightFlowSt
     }
 
     /**
-     * @deprecated provided for Be-release as backward compatibility relic
+     * Get flow statistics.
+     *
+     * @deprecated provided for Be-release as backward compatibility relic.
      */
     @Override
     @Deprecated
-    public Future<RpcResult<GetAllFlowsStatisticsFromAllFlowTablesOutput>> getAllFlowsStatisticsFromAllFlowTables(
-            final GetAllFlowsStatisticsFromAllFlowTablesInput input) {
+    public ListenableFuture<RpcResult<GetAllFlowsStatisticsFromAllFlowTablesOutput>>
+        getAllFlowsStatisticsFromAllFlowTables(final GetAllFlowsStatisticsFromAllFlowTablesInput input) {
         if (delegate != null) {
             return delegate.getAllFlowsStatisticsFromAllFlowTables(input);
         } else {
@@ -108,11 +117,13 @@ public class OpendaylightFlowStatisticsServiceImpl implements OpendaylightFlowSt
     }
 
     /**
-     * @deprecated provided for Be-release as backward compatibility relic
+     * Get flow statistics.
+     *
+     * @deprecated provided for Be-release as backward compatibility relic.
      */
     @Override
     @Deprecated
-    public Future<RpcResult<GetFlowStatisticsFromFlowTableOutput>> getFlowStatisticsFromFlowTable(
+    public ListenableFuture<RpcResult<GetFlowStatisticsFromFlowTableOutput>> getFlowStatisticsFromFlowTable(
             final GetFlowStatisticsFromFlowTableInput input) {
         if (delegate != null) {
             return delegate.getFlowStatisticsFromFlowTable(input);