ProducerManager { public void shutdown() { log.info("Stop producer manager"); transientProducerScheduler.shutdown(); } ProducerManager(final SchedulerDriver schedulerDriver, final CoordinatorRegistryCenter regCenter); void startup(); void register(final CloudJobConfigurationPOJO cloudJobConfig); void update(final CloudJobConfigurationPOJO cloudJobConfig); void deregister(final String jobName); void schedule(final CloudJobConfigurationPOJO cloudJobConfig); void unschedule(final String jobName); void reschedule(final String jobName); void sendFrameworkMessage(final ExecutorID executorId, final SlaveID slaveId, final byte[] data); void shutdown();  }
@Test public void assertShutdown() { producerManager.shutdown(); verify(transientProducerScheduler).shutdown(); }