natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update ReplierDispatcherTest test case

This commit is contained in:
Albumen Kevin 2023-09-26 15:29:31 +08:00
parent 5aa99c526f
commit e0ca51d0b0
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dubbo-remoting/dubbo-remoting-netty4/src/test/java/org/apache/dubbo/remoting/transport/netty4/ReplierDispatcherTest.java
View File

@ -109,7 +109,7 @@ class ReplierDispatcherTest {
try {
clientExchangeInfo(port);
} catch (Exception e) {
fail();
fail(e);
}
}));
for (Future<?> future : futureList) {
@ -120,7 +120,7 @@ class ReplierDispatcherTest {
}
void clientExchangeInfo(int port) throws Exception {
ExchangeChannel client = Exchangers.connect(URL.valueOf("exchange://localhost:" + port + "?" + CommonConstants.TIMEOUT_KEY + "=5000"));
ExchangeChannel client = Exchangers.connect(URL.valueOf("exchange://localhost:" + port + "?" + CommonConstants.TIMEOUT_KEY + "=60000"));
clients.put(Thread.currentThread().getName(), client);
MockResult result = (MockResult) client.request(new RpcMessage(DemoService.class.getName(), "plus", new Class<?>[]{int.class, int.class}, new Object[]{55, 25})).get();
Assertions.assertEquals(result.getResult(), 80);