Do you "Shutting down Thread: " in the output? Are all threads shut down?
Thanks,
Jun
On Wed, Aug 28, 2013 at 1:52 PM, David Williams wrote:
> Hi Jun,
>
> Thanks for following up. I removed the statement but still see no
> messages from the producer. Also when that statement is in with the
>
Hi Jun,
Thanks for following up. I removed the statement but still see no
messages from the producer. Also when that statement is in with the
single threaded consumer example, it prints "non-empty iterator" for its
toString method versus "empty iterator" in the non working multi stream
example.
Could you remove the following statement and see if it works?
System.out.println("Created iterator " + it.toString() + " thread number "
+ threadNumber);
Thanks,
Jun
On Tue, Aug 27, 2013 at 3:43 PM, David Williams wrote:
>
> Hi all,
>
> I checked out the java source and looked at the java exa
Hi all,
I checked out the java source and looked at the java examples. They worked
well in my IDE and on the console. However, I also tried the threaded example
following the consumer group example. The problem is, this example is not
working and toString on the stream iterator returns the
