So I can successfully forward messages from an Akka HTTP websocket -> rabbitmq and back. However, I appear to be having some issues when I have multiple clients. Here is the Flow I have:
WS client --> Akka HTTP Websocket Source -> Flow[Message] (map to ByteString) -> RabbitMQ sink (queue1) --> RabbitMQ source --> Flow[IncomingMessage] --> mapAsync(serverActor) --> RabbitMQ sink (queue2) --> Flow[ByteString] (map to TextMessage) --> WS client
Rather long winded, but I basically have a stretched out Websockets flow with two separate rabbitmq queues. The question I have is how can I correlate so that the WS client id is the same? It seems that the return leg via RabbitMQ back to the websocket doesn’t always know which client it is connected to, so either client might receive the message.
Any tips would be most appreciated!