Re: Server load - Topology optimization

[Sean Zhong]

What is the type of _collector?

If it is SpoutOutputCollector, you can change from:
        if(message instanceof MonetiseEvent)
        {
            logger.log(Level.DEBUG, "recieved monetise message");
            _collector.emit(new Values(message));
            _collector.ack(tuple);
        }

to
      Integer msgId = new Integer(0); //can be any object
        if(message instanceof MonetiseEvent)
        {
            logger.log(Level.DEBUG, "recieved monetise message");
            _collector.emit(new Values(message), msgId);
            _collector.ack(tuple);
        }



On Thu, Mar 20, 2014 at 12:18 AM, David Crossland <da...@elastacloud.com>wrote:

> _collector.emit(new Values(message));