.
.
.
.
.
Uses a LinkedBlockingQueue rather than an ArrayBlockingQueue, which does not have a fixed memory and allows growth. Adds a LoadTest, which caught that problem.
Found a reproducible load test that consistently fails. Debugging it now to find what is broken.
Adding some realtime monitoring of the internal state of the nodes. Try going to /varz and taking from there.