Re: Server load - Topology optimization

[David Crossland]

I added a message id in the spout, now I get acks on my spout, thanks for 
that.. looks like I've got a 1267.486 latency on completion.. time to reduce 
the number of executors methinks..

D

From: Sean Zhong<mailto:clock...@gmail.com>
Sent: ?Thursday?, ?20? ?March? ?2014 ?01?:?52
To: user@storm.incubator.apache.org<mailto:user@storm.incubator.apache.org>


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<mailto:da...@elastacloud.com>> wrote:
_collector.emit(new Values(message));