TransientProducerScheduler { void shutdown() { try { if (null != scheduler && !scheduler.isShutdown()) { scheduler.shutdown(); } } catch (final SchedulerException ex) { throw new JobSystemException(ex); } repository.removeAll(); } TransientProducerScheduler(final ReadyService readyService);   }
@Test public void assertShutdown() throws SchedulerException { transientProducerScheduler.shutdown(); verify(scheduler).isShutdown(); verify(scheduler).shutdown(); }