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