Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 // Copyright (c) P. Taylor Goetz (ptgoetz@gmail.com)
 
 package backtype.storm.contrib.signals.test;
 
 import  backtype.storm.Config;
 import  backtype.storm.LocalCluster;
 import  backtype.storm.topology.TopologyBuilder;
 import  backtype.storm.utils.Utils;
 
public class SignalTopology {

    

Parameters:
args
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        TopologyBuilder builder = new TopologyBuilder();
        builder.setSpout("signal-spout"new TestSignalSpout("test-signal-spout"));
        Config conf = new Config();
        conf.setDebug(true);
        LocalCluster cluster = new LocalCluster();
        cluster.submitTopology("test"confbuilder.createTopology());
        Utils.sleep(120000);
        cluster.killTopology("test");
        cluster.shutdown();
    }
New to GrepCode? Check out our FAQ X