This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/master by this push: new 5b4816d fix:Remove unused variable parameters in AbstractProxyInvoker (#5651) 5b4816d is described below commit 5b4816dfa6ae92d0b94af4ed41c07ca6c9d0fcb9 Author: LiosWong <diy...@163.com> AuthorDate: Sun Feb 9 12:56:11 2020 +0800 fix:Remove unused variable parameters in AbstractProxyInvoker (#5651) --- .../main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java index 6abac55..6d74825 100644 --- a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java +++ b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java @@ -82,7 +82,7 @@ public abstract class AbstractProxyInvoker<T> implements Invoker<T> { public Result invoke(Invocation invocation) throws RpcException { try { Object value = doInvoke(proxy, invocation.getMethodName(), invocation.getParameterTypes(), invocation.getArguments()); - CompletableFuture<Object> future = wrapWithFuture(value, invocation); + CompletableFuture<Object> future = wrapWithFuture(value); CompletableFuture<AppResponse> appResponseFuture = future.handle((obj, t) -> { AppResponse result = new AppResponse(); if (t != null) { @@ -107,7 +107,7 @@ public abstract class AbstractProxyInvoker<T> implements Invoker<T> { } } - private CompletableFuture<Object> wrapWithFuture (Object value, Invocation invocation) { + private CompletableFuture<Object> wrapWithFuture(Object value) { if (RpcContext.getContext().isAsyncStarted()) { return ((AsyncContextImpl)(RpcContext.getContext().getAsyncContext())).getInternalFuture(); } else if (value instanceof CompletableFuture) {