Decompose RPC implementation classes

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

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGroupDirectStatisticsService.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGetGroupStatistics.java
similarity index 57%
rename from openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGroupDirectStatisticsService.java
rename to openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGetGroupStatistics.java
index 08f753a46adbca119559dfb1c71cf4c9102796c6..bc563a23858e71a30fef825585516b05b21c0836 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGroupDirectStatisticsService.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/statistics/services/direct/AbstractGetGroupStatistics.java
@@ -5,32 +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.GetGroupStatistics;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetGroupStatisticsInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511.GetGroupStatisticsOutput;
 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 Group direct statistics service.
  */
-public abstract class AbstractGroupDirectStatisticsService<T extends OfHeader>
-        extends AbstractDirectStatisticsService<GetGroupStatisticsInput, GetGroupStatisticsOutput, T> {
+public abstract class AbstractGetGroupStatistics<T extends OfHeader>
+        extends AbstractDirectStatisticsService<GetGroupStatisticsInput, GetGroupStatisticsOutput, T>
+        implements GetGroupStatistics {
+    protected AbstractGetGroupStatistics(final RequestContextStack requestContextStack,
+            final DeviceContext deviceContext, final ConvertorExecutor convertorExecutor,
+            final MultipartWriterProvider statisticsWriterProvider) {
+        super(MultipartType.OFPMPGROUP, requestContextStack, deviceContext, convertorExecutor,
+            statisticsWriterProvider);
+    }
 
-    protected AbstractGroupDirectStatisticsService(final RequestContextStack requestContextStack,
-                                                   final DeviceContext deviceContext,
-                                                   final ConvertorExecutor convertorExecutor,
-                                                   final MultipartWriterProvider statisticsWriterProvider) {
-        super(MultipartType.OFPMPGROUP,
-                requestContextStack,
-                deviceContext,
-                convertorExecutor,
-                statisticsWriterProvider);
+    @Override
+    public final ListenableFuture<RpcResult<GetGroupStatisticsOutput>> invoke(final GetGroupStatisticsInput input) {
+        return handleAndReply(input);
     }
 }