Hello Rob, You're right, there was something strange in my question. I realized that it was not clear for me neither. I explored different strategies for the consumer broadcast. One was indeed to have the consumer to receive all the messages from the moment it connects and not keep the messages on the broker when all the consumers received them. Using a queue configured with "ensureNondestructiveConsumers", a replay period of 0 and a maxTtl of 10 seconds worked for me.
Thank you for the answer, Regards, Antoine -----Original Message----- From: Rob Godfrey [mailto:[email protected]] Sent: lundi 9 janvier 2017 15:40 To: [email protected] Subject: Re: Implementing consumer broadcast with a single queue with Qpid Java Broker 6.0.4 Hi Antoine, I'm not sure I'm totally clear on what you mean by "I cannot lose messages" in this context. Are you saying that if a consumer is connected, then it should receive all messages which arrive on the "topic" from the point at which it connects; but once all consumers have seen a message (or if there are no consumers connected) it is OK for the message to be deleted? -- Rob On 9 January 2017 at 14:34, Antoine Chevin <[email protected]> wrote: > Hello, > > I analyzed if it is possible to broadcast messages using a single > queue. I know I could make the consumers listen to a topic but I > noticed that a temporary queue is created on the broker and I'm afraid > of the broker performance if hundreds of consumers listen to the topic. > > So far, I managed to broadcast in 2 ways: > - configure a queue on the broker configured with > "ensureNondestructiveConsumers" and a default filter with a replay > period to not receive all the message when a consumer connect. The > problem is that the messages on the queue are never cleared. A TTL can > solve that but I cannot lose messages. > - configure the dispatch router 0.6.1 to listen to the broker and > expose an address with the distribution "multicast". This works very well. > > To cover use cases where only the Qpid java broker can be used, I > wonder if you know other solutions to broadcast a message to consumers > using a single queue? > > Thanks in advance, > Best regards, > Antoine >
