Decompose RPC implementation classes

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

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractMeterDirectStatisticsService.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGetMeterStatistics.java
similarity index 60%
rename from openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractMeterDirectStatisticsService.java
rename to openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGetMeterStatistics.java
index 4b94417cb9da46dfa31412f89db361d1140f8d81..5936a37681d16f4ea4f88a311ca6ce8379163b21 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractMeterDirectStatisticsService.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGetMeterStatistics.java
@@ -5,30 +5,35 @@
  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
  * and is available at http://www.eclipse.org/legal/epl-v10.html
  */
-
 package org.opendaylight.openflowplugin.impl.statistics.services.direct;
 
+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.impl.datastore.MultipartWriterProvider;
 import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorExecutor;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetMeterStatistics;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetMeterStatisticsInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetMeterStatisticsOutput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
+import org.opendaylight.yangtools.yang.common.RpcResult;
 
 /**
  * The Meter direct statistics service.
  */
-public abstract class AbstractMeterDirectStatisticsService<T extends OfHeader> extends
-        AbstractDirectStatisticsService<GetMeterStatisticsInput, GetMeterStatisticsOutput, T> {
-
-    public AbstractMeterDirectStatisticsService(final RequestContextStack requestContextStack,
-                                                final DeviceContext deviceContext,
-                                                final ConvertorExecutor convertorExecutor,
-                                                final MultipartWriterProvider statisticsWriterProvider) {
+public abstract class AbstractGetMeterStatistics<T extends OfHeader>
+        extends AbstractDirectStatisticsService<GetMeterStatisticsInput, GetMeterStatisticsOutput, T>
+        implements GetMeterStatistics {
+    protected AbstractGetMeterStatistics(final RequestContextStack requestContextStack,
+            final DeviceContext deviceContext, final ConvertorExecutor convertorExecutor,
+            final MultipartWriterProvider statisticsWriterProvider) {
         super(MultipartType.OFPMPMETER, requestContextStack, deviceContext, convertorExecutor,
                 statisticsWriterProvider);
     }
 
+    @Override
+    public final ListenableFuture<RpcResult<GetMeterStatisticsOutput>> invoke(final GetMeterStatisticsInput input) {
+        return handleAndReply(input);
+    }
 }