Decompose RPC implementation classes

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

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SalPortServiceImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/UpdatePortImpl.java
similarity index 82%
rename from openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SalPortServiceImpl.java
rename to openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/UpdatePortImpl.java
index d6e149ceb52bdf2d4749cb5abaa3aa19813510e7..828ec24abb9212832b8854ecc830fab6c34f6093 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/SalPortServiceImpl.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/services/sal/UpdatePortImpl.java
@@ -21,18 +21,18 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.p
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortModInputBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.port.service.rev131107.SalPortService;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.port.service.rev131107.UpdatePort;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.service.rev131107.UpdatePortInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.service.rev131107.UpdatePortOutput;
 import org.opendaylight.yangtools.yang.common.RpcResult;
 
-public final class SalPortServiceImpl
-        extends AbstractSimpleService<UpdatePortInput, UpdatePortOutput> implements SalPortService {
+public final class UpdatePortImpl extends AbstractSimpleService<UpdatePortInput, UpdatePortOutput>
+        implements UpdatePort {
     private final ConvertorExecutor convertorExecutor;
     private final VersionConvertorData data;
     private final SingleLayerPortService<UpdatePortOutput> portMessage;
 
-    public SalPortServiceImpl(final RequestContextStack requestContextStack,
+    public UpdatePortImpl(final RequestContextStack requestContextStack,
                               final DeviceContext deviceContext,
                               final ConvertorExecutor convertorExecutor) {
         super(requestContextStack, deviceContext, UpdatePortOutput.class);
@@ -42,7 +42,7 @@ public final class SalPortServiceImpl
     }
 
     @Override
-    public ListenableFuture<RpcResult<UpdatePortOutput>> updatePort(final UpdatePortInput input) {
+    public ListenableFuture<RpcResult<UpdatePortOutput>> invoke(final UpdatePortInput input) {
         return portMessage.canUseSingleLayerSerialization()
             ? portMessage.handleServiceCall(getPortFromInput(input))
             : handleServiceCall(input);
@@ -50,14 +50,11 @@ public final class SalPortServiceImpl
 
     @Override
     protected OfHeader buildRequest(final Xid xid, final UpdatePortInput input) {
-        final Optional<PortModInput> ofPortModInput = convertorExecutor
-            .convert(getPortFromInput(input), data);
+        final Optional<PortModInput> ofPortModInput = convertorExecutor.convert(getPortFromInput(input), data);
 
-        final PortModInputBuilder mdInput = new PortModInputBuilder(ofPortModInput
-                .orElse(PortConvertor.defaultResult(getVersion())))
-                .setXid(xid.getValue());
-
-        return mdInput.build();
+        return new PortModInputBuilder(ofPortModInput.orElse(PortConvertor.defaultResult(getVersion())))
+            .setXid(xid.getValue())
+            .build();
     }
 
     private static Port getPortFromInput(final UpdatePortInput input) {