Decompose RPC implementation classes

[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / services / singlelayer / SetAsyncImpl.java

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/singlelayer/SingleLayerSetAsyncConfigService.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/singlelayer/SetAsyncImpl.java
similarity index 69%
rename from openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/singlelayer/SingleLayerSetAsyncConfigService.java
rename to openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/singlelayer/SetAsyncImpl.java
index bbfc248cb8eb85376b5f7f75453ca7438f3e4513..fef91466171447af41f0fce29004513a4cd37953 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/singlelayer/SingleLayerSetAsyncConfigService.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/singlelayer/SetAsyncImpl.java
@@ -5,27 +5,33 @@
  * 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.services.singlelayer;
 
+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.Xid;
 import org.opendaylight.openflowplugin.impl.services.AbstractSimpleService;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.async.config.service.rev170619.AsyncConfigMessageBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.async.config.service.rev170619.SetAsync;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.async.config.service.rev170619.SetAsyncInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.async.config.service.rev170619.SetAsyncOutput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
+import org.opendaylight.yangtools.yang.common.RpcResult;
 
-public class SingleLayerSetAsyncConfigService extends AbstractSimpleService<SetAsyncInput, SetAsyncOutput> {
-
-    public SingleLayerSetAsyncConfigService(final RequestContextStack requestContextStack,
+public final class SetAsyncImpl extends AbstractSimpleService<SetAsyncInput, SetAsyncOutput> implements SetAsync {
+    public SetAsyncImpl(final RequestContextStack requestContextStack,
                                             final DeviceContext deviceContext) {
         super(requestContextStack, deviceContext, SetAsyncOutput.class);
     }
 
     @Override
-    protected OfHeader buildRequest(Xid xid, SetAsyncInput input) {
+    public ListenableFuture<RpcResult<SetAsyncOutput>> invoke(final SetAsyncInput input) {
+        return handleServiceCall(input);
+    }
+
+    @Override
+    protected OfHeader buildRequest(final Xid xid, final SetAsyncInput input) {
         return new AsyncConfigMessageBuilder(input)
                 .setVersion(getVersion())
                 .setXid(xid.getValue())