code: @Override
      public void prepare(Map stormConf, TopologyContext topologyContext, OutputCollector outputCollector) {
          this.outputCollector = outputCollector;
          this.client = clientFactory.makeClient(stormConf);
          this.queue = new LinkedBlockingQueue<>(QUEUE_MAX_SIZE);
      }
docs: (non-Javadoc)
  @see backtype.storm.task.IBolt#prepare(java.util.Map, backtype.storm.task.TopologyContext, backtype.storm.task.OutputCollector)