I'm using rabbitmq to propagate a singular varying state to multiple consumers (one-to-many relationship). When a new consumer connects, it declares its own queue and binds it to the exchange where state updates are published. The state is always published "completely", so no deltas just yet.
I need a way to propagate the last known good state to a newly connected consumer, or to somehow make this consumer "catch up" with the rest. Using a more tightly coupled communication system (like GRPC) it's easy to send snapshot on initial connection, also using things like
Retained Messages in mqtt.
How can I achieve similar behaviour in rmq?
question from:
https://stackoverflow.com/questions/65897619/sending-last-known-good-state-to-new-consumers 与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…