code: void prepare(Map stormConf, TopologyContext context, OutputCollector collector, State state) {
          init(context, collector);
          this.collector = new AckTrackingOutputCollector(collector);
          bolt.prepare(stormConf, context, this.collector);
          this.state = state;
      }
docs: package access for unit tests