This is an automated email from the ASF dual-hosted git repository.

liujun pushed a commit to branch 3.x-dev
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git


The following commit(s) were added to refs/heads/3.x-dev by this push:
     new ad09f7a  does not need to get timeout.
ad09f7a is described below

commit ad09f7a8717b89c676a8c8e8ba2b19ba9cb02e3a
Author: ken.lj <[email protected]>
AuthorDate: Thu May 23 12:57:52 2019 +0800

    does not need to get timeout.
---
 .../main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
 
b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
index 9f1725d..5c06b4e 100644
--- 
a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
+++ 
b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
@@ -27,7 +27,6 @@ import org.apache.dubbo.rpc.RpcException;
 import org.apache.dubbo.rpc.RpcInvocation;
 
 import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeUnit;
 
 /**
  * This class will work as a wrapper wrapping outside of each protocol invoker.
@@ -52,7 +51,7 @@ public class AsyncToSyncInvoker<T> implements Invoker<T> {
 
         try {
             if (InvokeMode.SYNC == 
((RpcInvocation)invocation).getInvokeMode()) {
-                
asyncResult.get(invoker.getUrl().getMethodParameter(invocation.getMethodName(), 
"timeout", 1000), TimeUnit.MILLISECONDS);
+                asyncResult.get();
             }
         } catch (InterruptedException e) {
             throw new RpcException("Interrupted unexpectedly while waiting for 
remoting result to return!  method: " + invocation.getMethodName() + ", 
provider: " + getUrl() + ", cause: " + e.getMessage(), e);

Reply via email to