Have you tried RMQ streams? Seemed compelling but I haven't needed it yet.

I would really like a stream messaging system like this I can put in my supervision tree.