RabbitMQ Publish Subscribe and late Joiners

[Wilfredo Velazquez-Rodriguez]

Hey all, 

I am getting my feet wet with RabbitMQ and I am interested in using it as the backbone of the networking for an application I'm building. 

A part of this is an application that produces some soft real-time data based on 'sessions'. Eg a user logs in which begins a session, then they click buttons, toggle switches etc

I want to have a second application that is able to view active sessions and be able to 'connect' and view all events, past and future for that session.

There can be multiple of these 'monitor' applications running at once and they should all see the same events.

tldr; simple pub/sub. Except with multiple late-join subscribers that need to get the full message history

Reading through the docs my initial thought is that there should be some way to address this using topic exchanges, but I cannot figure out the 'late join' aspect of it.

I can always 

1. write logic into the producer to track late joins and publish the entire session only to that late joiner, but this couples the producer to clients and introduces race condition/ordering issues

2. Write a dedicated broker application to do what #1 does but still has race conditions I'd need to address somehow

Does anyone have any thoughts on how/if I can address this with RabbitMQ? I may very well be missing something or thinking about the problem all wrong.

Thanks!

- Wilfredo Velazquez-Rodriguez

[Michal Kuratczyk]

Hi,

Sounds like you are looking for Streams: https://blog.rabbitmq.com/posts/2021/07/rabbitmq-streams-overview/

Best,

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/10ad4814-59ac-4771-8297-703170186e3en%40googlegroups.com.

--

Michał

RabbitMQ team

[Wilfredo Velazquez]

That's exactly what I was looking for, thank you!

You received this message because you are subscribed to a topic in the Google Groups "rabbitmq-users" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/rabbitmq-users/7bQo4Z0eQxw/unsubscribe.
To unsubscribe from this group and all its topics, send an email to rabbitmq-user...@googlegroups.com.
To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/CAA81d0v2_Y-k3tZ0TwPXGbVn%3DmN6KHC%2BrFwB-RtEZO_TQSkjvw%40mail.gmail.com.

--

Wilfredo Velázquez-Rodríguez