Understanding multi-process queue #1153
-
Hello! Could someone please explain me how does multi-process queue work with different message queues in case of emitting an event to a room? As I see in the code, participants of rooms are stored locally in each particular process, so the particular process knows only room subscribers that are connected only to this process. I'm new into MQs so sorry if it's a stupid question. As I understood:
I see that you support all of these MQs (SQS via kombu), but I don't understand how you accomplish consistency in all of them. So, as I understand, in case of RabbitMQ and SQS, message will be received by only one process of my app and that means that only small part of the room get the emitted message, right? And only in case of Redis-like emits to room will reach all room participants? Isn't it a bug? Thank you, |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment 1 reply
-
See the fanout exchange. |
Beta Was this translation helpful? Give feedback.
See the fanout exchange.