code: @Override
      protected void onStart() {
          logger.info("Starting DoTaskApp... App Partition [{}]", this.getPartitionId());
          // <<<<<<< HEAD Task doesn't have start in latest storm-impl
          // TODO change the way the app starts
          // if (this.getPartitionId() == 0)
          S4Topology s4topology = (S4Topology) getTask().getTopology();
          S4EntranceProcessingItem epi = (S4EntranceProcessingItem) s4topology.getEntranceProcessingItem();
          while (epi.injectNextEvent())
              // inject events from the EntrancePI
              ;
      }
docs: /*
  (non-Javadoc)
  
  @see org.apache.s4.core.App#onStart()