@Test void testShutdown_ExecutorServiceUsed() { testSubject.shutdown(); verify(executorService).shutdown(); }
public void shutdown() { if (executor instanceof ExecutorService) { ((ExecutorService) executor).shutdown(); try { ((ExecutorService) executor).awaitTermination(5, TimeUnit.SECONDS); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }
AsynchronousCommandBus extends SimpleCommandBus { public void shutdown() { if (executor instanceof ExecutorService) { ((ExecutorService) executor).shutdown(); try { ((ExecutorService) executor).awaitTermination(5, TimeUnit.SECONDS); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } } }
AsynchronousCommandBus extends SimpleCommandBus { public void shutdown() { if (executor instanceof ExecutorService) { ((ExecutorService) executor).shutdown(); try { ((ExecutorService) executor).awaitTermination(5, TimeUnit.SECONDS); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } } protected  AsynchronousCommandBus(Builder builder); }
AsynchronousCommandBus extends SimpleCommandBus { public void shutdown() { if (executor instanceof ExecutorService) { ((ExecutorService) executor).shutdown(); try { ((ExecutorService) executor).awaitTermination(5, TimeUnit.SECONDS); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } } protected  AsynchronousCommandBus(Builder builder); static Builder builder(); void shutdown(); }
AsynchronousCommandBus extends SimpleCommandBus { public void shutdown() { if (executor instanceof ExecutorService) { ((ExecutorService) executor).shutdown(); try { ((ExecutorService) executor).awaitTermination(5, TimeUnit.SECONDS); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } } protected  AsynchronousCommandBus(Builder builder); static Builder builder(); void shutdown();  }