@Override
          public void afterStart() {
            processorListenerState.put(ListenerCallback.AFTER_START, true);
            processorListenerStart.countDown();
          }
Tests stop() method when Container AND JobCoordinator are running
samza-core/src/test/java/org/apache/samza/processor/TestStreamProcessor.java