switch active consumer but failed about pulsar

[merlimat]

This part of code gets executed every time a consumer connects and we never saw this error.

Collections.sort() should not call set() on the iterator itself, and in the latest JDK it's not doing it. I also don't see that line at Collections.java:234. Can you specify which JDK version you're using?

In any case, in PersistentDispatcherSingleActiveConsumer.java:75 using list.sort() instead of Collections.sort(list) might fix the issue.

[merlimat]

Just verified, earlier JDK8 versions were using the iterator.set() instead of relying on the list.sort() interface.

Workaround for now is to upgrade your JDK.

[chakra-coder]

ok, thanks very much.

[chakra-coder]

my jdk info is (running on ubuntu:14.04):
java version "1.8.0_11"
Java(TM) SE Runtime Environment (build 1.8.0_11-b12)
Java HotSpot(TM) 64-Bit Server VM (build 25.11-b03, mixed mode)

[merlimat]

It was fixed in jdk-1.8.0_20 : http://bugs.java.com/view_bug.do?bug_id=8032636