activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "this.juan" <>
Subject Incremental updates and QueryBasedSubscriptionRecoveryPolicy
Date Sat, 30 Apr 2011 13:52:12 GMT

This is what I'd like to do:

* Clients subscribe to a Topic, when the client starts they need first to
receive a initial message (current state of some data in the producer). With
this initial message in place, its enough to receive incremental updates of
the data.
* The initial message is expensive (in size).
* The incremental updates are small but frequent.

I've read about the QueryBasedSubscriptionRecoveryPolicy where I can
override a method in a MessageQuery to get this initial message. However,
what would happen if N clients try to subscribe to the topic at the *same*
time, will the producer get hit N times? Or does the broker cache the
initial message?

It's not clear to me how the recovery policy works in the broker in this
kind of situation. In my case the producer will be busy processing (which
result in the incremental updates), so with many consumer starting
frequently, it may not be able to respond fast enough.
View this message in context:
Sent from the ActiveMQ - User mailing list archive at

View raw message