ClusterBasedProcessorLifecycleListener implements SamzaContainerListener { @Override public void afterStart() { log.info("Container Started"); processorLifecycleListener.afterStart(); } ClusterBasedProcessorLifecycleListener(Config config, ProcessorLifecycleListener processorLifecycleListener,
      Runnable shutdownHookCallback); @Override void beforeStart(); @Override void afterStart(); @Override void afterStop(); @Override void afterFailure(Throwable t);  }
@Test public void testLifecycleListenerAfterStart() { clusterBasedProcessorLifecycleListener.afterStart(); Mockito.verify(processorLifecycleListener).afterStart(); }