Hey Anh, You are not meant to hold on to the MessageCollector or re-use it between process invocations. If you hold onto it, and call send() after the process method has returned (or in a subsequent invocation), your message will be put into a buffer that's never sent. If you continue doing this, it's likely that your container will run out of memory.
Cheers, Chris On 3/7/14 9:44 AM, "Anh Thu Vu" <[email protected]> wrote: >Hi all, > >About the MessageCollector(s) that is passed to the StreamTask in >process() >method, is the MessageCollector passed to each invocation of the method >the >same instance? >If they are different for each invocation, what will happen if I use the >old MessageCollector (that was passed to the StreamTask with some previous >messages) to send out new messages? > >Thanks, >Casey
