X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fimplementation%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnector%2Fremoterpc%2Futils%2FRemoteServerTestClient.java;h=7a4f4a5974606c945a3538fcebe8623f226ddc03;hp=a71ab865aa717b84edcc615a6f01d750ac417132;hb=a31a4448ea6665317f4af41ae26d804829418c04;hpb=7dd4359be20305d236a08c6b2db0c001cf7d7754 diff --git a/opendaylight/md-sal/sal-remoterpc-connector/implementation/src/test/java/org/opendaylight/controller/sal/connector/remoterpc/utils/RemoteServerTestClient.java b/opendaylight/md-sal/sal-remoterpc-connector/implementation/src/test/java/org/opendaylight/controller/sal/connector/remoterpc/utils/RemoteServerTestClient.java index a71ab865aa..7a4f4a5974 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/implementation/src/test/java/org/opendaylight/controller/sal/connector/remoterpc/utils/RemoteServerTestClient.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/implementation/src/test/java/org/opendaylight/controller/sal/connector/remoterpc/utils/RemoteServerTestClient.java @@ -1,14 +1,14 @@ package org.opendaylight.controller.sal.connector.remoterpc.utils; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; + import org.opendaylight.controller.sal.connector.api.RpcRouter; import org.opendaylight.controller.sal.connector.remoterpc.dto.Message; import org.opendaylight.controller.sal.connector.remoterpc.util.XmlUtils; import org.opendaylight.yangtools.yang.data.api.CompositeNode; import org.zeromq.ZMQ; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; - public class RemoteServerTestClient { @@ -39,7 +39,7 @@ public class RemoteServerTestClient { } public Message createAddFlowMessage(String serverAddress ){ - RpcRouter.RouteIdentifier routeIdentifier = getAddFlowRpcIdentifier(); + RpcRouter.RouteIdentifier routeIdentifier = getAddFlowRpcIdentifier(); Message addFlow = new Message.MessageBuilder() .type(Message.MessageType.REQUEST) @@ -52,7 +52,7 @@ public class RemoteServerTestClient { return addFlow; } - private RpcRouter.RouteIdentifier getAddFlowRpcIdentifier(){ + private RpcRouter.RouteIdentifier getAddFlowRpcIdentifier(){ throw new UnsupportedOperationException(); }