@Override
    public void afterStop() {
      closeAndRemoveProcessor();
      // successful shutdown
      handleProcessorShutdown(null);
    }
Defines a specific implementation of {@link ProcessorLifecycleListener} for local {@link StreamProcessor}s.
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java