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