I was looking at the documentation last night, I understand I need only specify some message id in the spout. Is this correct?
I would expect every message would need a unique id, i suppose a UUID could be used? David From: Sean Zhong<mailto:[email protected]> Sent: ?Thursday?, ?20? ?March? ?2014 ?01?:?52 To: [email protected]<mailto:[email protected]> 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 <[email protected]<mailto:[email protected]>> wrote: _collector.emit(new Values(message));
