X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=binding%2Fmdsal-binding-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fbinding%2Fapi%2FRpcConsumerRegistry.java;h=d2e0e985fee66795133bf22daa258c8001b96fa3;hb=104afbbc04792df68ee001c14fb02171d640f889;hp=755b88c976781ebff0a5663fd7f5aea944ef579a;hpb=703b1cac5f0bdd429dcb64809b7cd599e973877f;p=mdsal.git diff --git a/binding/mdsal-binding-api/src/main/java/org/opendaylight/mdsal/binding/api/RpcConsumerRegistry.java b/binding/mdsal-binding-api/src/main/java/org/opendaylight/mdsal/binding/api/RpcConsumerRegistry.java index 755b88c976..d2e0e985fe 100644 --- a/binding/mdsal-binding-api/src/main/java/org/opendaylight/mdsal/binding/api/RpcConsumerRegistry.java +++ b/binding/mdsal-binding-api/src/main/java/org/opendaylight/mdsal/binding/api/RpcConsumerRegistry.java @@ -14,6 +14,7 @@ import org.opendaylight.yangtools.yang.binding.RpcService; /** * Provides access to registered Remote Procedure Call (RPC) service implementations. The RPCs are * defined in YANG models. + * *

* RPC implementations are registered using the {@link RpcProviderService}. * @@ -25,8 +26,8 @@ public interface RpcConsumerRegistry extends BindingService { *

* The returned instance is not an actual implementation of the RPC service interface, but a * proxy implementation of the interface that forwards to an actual implementation, if any. - *

* + *

* The following describes the behavior of the proxy when invoking RPC methods: *

* * The returned proxy is automatically updated with the most recent registered implementation. + * *

* The generated RPC method APIs require implementors to return a * {@link java.util.concurrent.Future Future} instance that wraps the @@ -46,13 +48,14 @@ public interface RpcConsumerRegistry extends BindingService { * {@link java.util.concurrent.Future Future} result. Instead, it is recommended to use * {@link com.google.common.util.concurrent.JdkFutureAdapters#listenInPoolThread(java.util.concurrent.Future)} * or - * {@link com.google.common.util.concurrent.JdkFutureAdapters#listenInPoolThread(java.util.concurrent.Future, java.util.concurrent.Executor)} - * to listen for Rpc Result. This will asynchronously listen for future result in executor and - * will not block current thread. + * {@link com.google.common.util.concurrent.JdkFutureAdapters#listenInPoolThread(java.util.concurrent.Future, + * java.util.concurrent.Executor)} to listen for Rpc Result. This will asynchronously listen for future result + * in executor and will not block current thread. * *

      *   final Future<RpcResult<SomeRpcOutput>> future = someRpcService.someRpc( ... );
-     *   Futures.addCallback(JdkFutureAdapters.listenInThreadPool(future), new FutureCallback<RpcResult<SomeRpcOutput>>() {
+     *   Futures.addCallback(JdkFutureAdapters.listenInThreadPool(future), new FutureCallback<RpcResult<
+     *   SomeRpcOutput>>() {
      *
      *       public void onSuccess(RpcResult<SomeRpcOutput> result) {
      *          // process result ...