flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
/**
	 * Tests that exception thrown in the postStop method are returned by the termination
	 * future.
	 */
Tests that exception thrown in the postStop method are returned by the termination
future.
Tests that exception thrown in the postStop method are returned by the termination future .
@Test
	public void testPostStopExceptionPropagation() throws Exception {
		FailingPostStopEndpoint rpcEndpoint = new FailingPostStopEndpoint(akkaRpcService, "FailingPostStopEndpoint");
		rpcEndpoint.start();
		rpcEndpoint.shutDown();
		CompletableFuture<Boolean> terminationFuture = rpcEndpoint.getTerminationFuture();
		try {
			terminationFuture.get();
		} catch (ExecutionException e) {
			assertTrue(e.getCause() instanceof FailingPostStopEndpoint.PostStopException);
		}
	}
@ Test public void testPostStopExceptionPropagation ( ) throws Exception { FailingPostStopEndpoint rpcEndpoint = new FailingPostStopEndpoint ( akkaRpcService , "FailingPostStopEndpoint" ) ; rpcEndpoint . start ( ) ; rpcEndpoint . shutDown ( ) ; CompletableFuture < Boolean > terminationFuture = rpcEndpoint . getTerminationFuture ( ) ; try { terminationFuture . get ( ) ; } catch ( ExecutionException e ) { assertTrue ( e . getCause ( ) instanceof FailingPostStopEndpoint . PostStopException ) ; } }
Tests that exception thrown in the postStop method are returned by the termination
 future.
Tests that exception thrown in the postStop method are returned by the termination future .