@ Override public void open ( Map < String , Object > map , TopologyContext ctx , SpoutOutputCollector collector ) { spoutOutputCollector = collector ; }
These three methods are required to extend the BaseRichSpout abstract class