Skip to content

Commit

Permalink
Update ReplierDispatcherTest test case
Browse files Browse the repository at this point in the history
  • Loading branch information
AlbumenJ committed Sep 26, 2023
1 parent 5aa99c5 commit e0ca51d
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ void testMultiThread() throws Exception {
try {
clientExchangeInfo(port);
} catch (Exception e) {
fail();
fail(e);
}
}));
for (Future<?> future : futureList) {
Expand All @@ -120,7 +120,7 @@ void testMultiThread() throws Exception {
}

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);
Expand Down

0 comments on commit e0ca51d

Please sign in to comment.