@Test
public void testRunTopology() throws InterruptedException {

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