@Test
public void testRunTopology() throws InterruptedException {

    Configuration conf = new Configuration();
    SentimentAnalysis topology = new SentimentAnalysis("sa", conf);
    
    StormRunner.runTopologyLocally(topology.buildTopology(), "sa", conf, 100);
}