Use the Storm's tick tuples feature for timing, and emit the tuples between ticks. Never sleep or block in nextTuple(), the method must be non-blocking.
On Tuesday, July 15, 2014, Telles Nobrega <[email protected]> wrote: > Hi, I'm working on a topology that the spout generates random numbers and > send it downstream. I need to control how many messages are sent per > second. I used a sleep in the spout nextTuple() but it doesn't seem to work > with more than 100 messages per second. Is there a better way to this? > > Thanks in advance, > > -- > ------------------------------------------ > Telles Mota Vidal Nobrega > M.sc. Candidate at UFCG > B.sc. in Computer Science at UFCG > Software Engineer at OpenStack Project - HP/LSD-UFCG > -- Danijel Schiavuzzi E: [email protected] W: www.schiavuzzi.com T: +385989035562 Skype: danijels7
