@@ -0,0 +1,1679 @@
+package eu.socialsensor.focused.crawler.spouts;%0A%0Aimport java.io.File;%0Aimport java.io.IOException;%0Aimport java.util.Map;%0A%0Aimport javax.xml.parsers.ParserConfigurationException;%0A%0Aimport org.xml.sax.SAXException;%0A%0Aimport eu.socialsensor.framework.streams.StreamException;%0Aimport eu.socialsensor.sfc.builder.InputConfiguration;%0Aimport eu.socialsensor.sfc.streams.StreamsManagerConfiguration;%0Aimport eu.socialsensor.sfc.streams.management.StreamsManager;%0Aimport backtype.storm.spout.SpoutOutputCollector;%0Aimport backtype.storm.task.TopologyContext;%0Aimport backtype.storm.topology.OutputFieldsDeclarer;%0Aimport backtype.storm.topology.base.BaseRichSpout;%0A%0Apublic class StreamManagerSpout  extends BaseRichSpout %7B%0A%0A%09/**%0A%09 * %0A%09 */%0A%09private static final long serialVersionUID = -5824716039413055289L;%0A%09private StreamsManagerConfiguration config;%0A%09private InputConfiguration inputConfig;%0A%0A%09public StreamManagerSpout(String streamConfig, String inputConfig) throws ParserConfigurationException, SAXException, IOException %7B%0A%09%09File streamConfigFile = new File(streamConfig);%0A%09%09File inputConfigFile = new File(inputConfig);%0A%09%09%0A%09%09this.config = StreamsManagerConfiguration.readFromFile(streamConfigFile);%09%09%0A%09%09this.inputConfig = InputConfiguration.readFromFile(inputConfigFile);%09%09%0A%09%7D%0A%09%0A%09public void open(@SuppressWarnings(%22rawtypes%22) Map conf, TopologyContext context,%0A%09%09%09SpoutOutputCollector collector) %7B%0A%09%09%0A%09%09StreamsManager manager;%0A%09%09try %7B%0A%09%09%09manager = new StreamsManager(config, inputConfig);%0A%09%09%09manager.open();%0A%09%09%09%0A%09%09%7D catch (StreamException e) %7B%0A%09%09%09e.printStackTrace();%0A%09%09%7D%0A%09%09%0A%09%7D%0A%0A%09public void nextTuple() %7B%0A%09%09%0A%09%7D%0A%0A%09public void declareOutputFields(OutputFieldsDeclarer declarer) %7B%09%0A%09%09%0A%09%7D%0A%0A%7D%0A

Add StreamManager spout