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) {

Reply via email to