Decompose RPC implementation classes

[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / services / sal / SendExperimenterMpRequestImpl.java

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SalExperimenterMpMessageServiceImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SendExperimenterMpRequestImpl.java
similarity index 77%
rename from openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SalExperimenterMpMessageServiceImpl.java
rename to openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SendExperimenterMpRequestImpl.java
index a7b45e567a6ea67f153669ec4563a0edb85ad518..627a6f3f186a297c7fcf6539613b4199cf514180 100755 (executable)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SalExperimenterMpMessageServiceImpl.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SendExperimenterMpRequestImpl.java
@@ -5,7 +5,6 @@
  * 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.sal;
 
 import com.google.common.util.concurrent.ListenableFuture;
@@ -14,27 +13,27 @@ import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
 import org.opendaylight.openflowplugin.extension.api.core.extension.ExtensionConverterProvider;
 import org.opendaylight.openflowplugin.impl.services.multilayer.MultiLayerExperimenterMultipartService;
 import org.opendaylight.openflowplugin.impl.services.singlelayer.SingleLayerExperimenterMultipartService;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.mp.message.service.rev151020.SalExperimenterMpMessageService;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.mp.message.service.rev151020.SendExperimenterMpRequest;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.mp.message.service.rev151020.SendExperimenterMpRequestInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.mp.message.service.rev151020.SendExperimenterMpRequestOutput;
 import org.opendaylight.yangtools.yang.common.RpcResult;
 
-public class SalExperimenterMpMessageServiceImpl implements SalExperimenterMpMessageService {
+public final class SendExperimenterMpRequestImpl implements SendExperimenterMpRequest {
     private final MultiLayerExperimenterMultipartService multiLayerService;
     private final SingleLayerExperimenterMultipartService singleLayerService;
 
-    public SalExperimenterMpMessageServiceImpl(final RequestContextStack requestContextStack,
+    public SendExperimenterMpRequestImpl(final RequestContextStack requestContextStack,
                                                final DeviceContext deviceContext,
                                                final ExtensionConverterProvider extensionConverterProvider) {
-        this.singleLayerService = new SingleLayerExperimenterMultipartService(requestContextStack, deviceContext,
+        singleLayerService = new SingleLayerExperimenterMultipartService(requestContextStack, deviceContext,
             extensionConverterProvider);
-        this.multiLayerService = new MultiLayerExperimenterMultipartService(requestContextStack, deviceContext,
+        multiLayerService = new MultiLayerExperimenterMultipartService(requestContextStack, deviceContext,
             extensionConverterProvider);
     }
 
     @Override
-    public ListenableFuture<RpcResult<SendExperimenterMpRequestOutput>>
-        sendExperimenterMpRequest(SendExperimenterMpRequestInput input) {
+    public ListenableFuture<RpcResult<SendExperimenterMpRequestOutput>> invoke(
+            final SendExperimenterMpRequestInput input) {
         return singleLayerService.canUseSingleLayerSerialization()
             ? singleLayerService.handleAndReply(input)
             : multiLayerService.handleAndReply(input);