Skip to content

Commit ad09f7a

Browse files
committed
does not need to get timeout.
1 parent 0d0ad0a commit ad09f7a

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import org.apache.dubbo.rpc.RpcInvocation;
2828

2929
import java.util.concurrent.ExecutionException;
30-
import java.util.concurrent.TimeUnit;
3130

3231
/**
3332
* This class will work as a wrapper wrapping outside of each protocol invoker.
@@ -52,7 +51,7 @@ public Result invoke(Invocation invocation) throws RpcException {
5251

5352
try {
5453
if (InvokeMode.SYNC == ((RpcInvocation)invocation).getInvokeMode()) {
55-
asyncResult.get(invoker.getUrl().getMethodParameter(invocation.getMethodName(), "timeout", 1000), TimeUnit.MILLISECONDS);
54+
asyncResult.get();
5655
}
5756
} catch (InterruptedException e) {
5857
throw new RpcException("Interrupted unexpectedly while waiting for remoting result to return! method: " + invocation.getMethodName() + ", provider: " + getUrl() + ", cause: " + e.getMessage(), e);

0 commit comments

Comments
 (0)