Yes, ConsumerIterator blocks when there is no new message. This is done by
calling take() on a blocking queue.
Thanks,
Jun
On Sun, Jan 5, 2014 at 5:53 PM, S Ahmed wrote:
> I'm trying to trace through the codebase and figure out where exactly the
> block occurs in the high level consumer?
>
>
I'm trying to trace through the codebase and figure out where exactly the
block occurs in the high level consumer?
public void run() {
ConsumerIterator it = m_stream.iterator();
while (it.hasNext())
System.out.println("Thread " + m_threadNumber + ": " + new
String(it.next().mess
