TwitterSpout.java

public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
    queue = new LinkedBlockingQueue<Status>(32*1024);
    _collector = collector;

    StatusListener listener = new StatusListener() {
        public void onStatus(Status status) {
            queue.offer(status);
        }
    }
}


public void nextTuple() {
    Status status = queue.poll();
    if (status != null) {
        _collector.emit(new Values(status));
    }
}