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

Reply via email to