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.bolt;
 
 import java.util.Map;
 
 import  org.slf4j.Logger;
 import  org.slf4j.LoggerFactory;
 
import  backtype.storm.task.OutputCollector;
import  backtype.storm.task.TopologyContext;
import  backtype.storm.topology.OutputFieldsDeclarer;
import  backtype.storm.topology.base.BaseRichBolt;
import  backtype.storm.tuple.Tuple;
public abstract class BaseSignalBolt extends BaseRichBolt implements SignalListener {
    private static final Logger LOG = LoggerFactory.getLogger(BaseSignalBolt.class);
    private String name;
    public BaseSignalBolt(String name) {
        this. = name;
    }
    @SuppressWarnings("rawtypes")
    @Override
    public void prepare(Map conf, TopologyContext context, OutputCollector collector) {
        try {
        	this. = new SignalConnection(this.this);
            this..init(conf);
        } catch (Exception e) {
            .error("Error SignalConnection."e);
        }
    }
	public void execute(Tuple input) {
		// TODO Auto-generated method stub
	}
	public void declareOutputFields(OutputFieldsDeclarer declarer) {
		// TODO Auto-generated method stub
	}
	public void onSignal(byte[] data) {
		// TODO Auto-generated method stub
	}
	public void cleanup() {
		// TODO Auto-generated method stub
		super.cleanup();
	}
    
    
New to GrepCode? Check out our FAQ X