I'm seeing duplicate messages in aleph, and was trying to figure out why that might be

It only seems to happen under load, I can't reproduce it consistently

Setup: /publish -> consume-async -> event bus /subscribe <- consume-async <- 10K buffered stream <- event bus

Also: /subscribe -> consume-async -> singleton Stomp protocol handler

Problem I'm seeing is on that last stream, the client is sending duplicate Stomp ACK messages, but AFAIK my code is not sending duplicate messages