- try {
- RpcInvocation.invoke(globalDOMRpcRoutingTableEntry.newInstance(rpcImplementations),
- TEST_CONTAINER).get(5, TimeUnit.SECONDS);
- fail("Expected DOMRpcImplementationNotAvailableException");
- } catch (ExecutionException e) {
- assertTrue(e.getCause() instanceof DOMRpcImplementationNotAvailableException);
- assertTrue(e.getCause().getMessage().contains(EXCEPTION_TEXT));
- }
+ final ListenableFuture<?> future = OperationInvocation.invoke(
+ globalDOMRpcRoutingTableEntry.newInstance(rpcImplementations), TEST_CONTAINER);
+
+ final ExecutionException ex = assertThrows(ExecutionException.class, () -> future.get(5, TimeUnit.SECONDS));
+ final Throwable cause = ex.getCause();
+ assertThat(cause, instanceOf(DOMRpcImplementationNotAvailableException.class));
+ assertThat(cause.getMessage(), containsString(EXCEPTION_TEXT));