class CustomProcessorBolt extends AbstractProcessorBolt {

    @Override
    public void prepare (Map stormConf, TopologyContext context, OutputCollector collector) {
        super.prepare(stormConf, context, collector);
        customProcessorRuntime = getCustomProcessorRuntime();
        customProcessorRuntime.initialize(config);
    }

}