search

mdevilliers / SignalR.RabbitMq

MessageBus implementation using RabbitMq as the backing store.
MIT License
89 stars 40 forks source link

Queues Filling Up #11

Closed gsogol closed 11 years ago

gsogol commented 11 years ago

What do you do with messages that were never picked up? Do you destroy them or do they stick around?

mdevilliers commented 11 years ago

Hey,

There shouldn't really ever be a backlog of messages needing cleared if the everything is functioning correctly.

We send messages to the exchanges which forward the messages to any listening queues.

If there aren't any queues the messages get dropped. If the queue disappears so do the messages. The messages should be getting acked almost immediately. The only time I've seen a build up of unacked messages was at a rate of round about 30,000 messages a second.

Are you getting a message build up?

gsogol commented 11 years ago

No it was more of a question. Thank you. What type of exchanges are created and are the queues and messages durable?

On Jun 10, 2013, at 10:29 AM, mdevilliers notifications@github.com wrote:

Hey,

There shouldn't really ever be a backlog of messages needing cleared if the everything is functioning correctly.

We send messages to the exchanges which forward the messages to any listening queues.

If there aren't any queues the messages get dropped. If the queue disappears so do the messages. The messages should be getting acked almost immediately. The only time I've seen a build up of unacked messages was at a rate of round about 30,000 messages a second.

Are you getting a message build up?

— Reply to this email directly or view it on GitHub.

mdevilliers commented 11 years ago

By default the exchange is fanout and the queues are transient and messages non durable.

gsogol commented 11 years ago

Got it. Thanks

On Jun 10, 2013, at 3:17 PM, mdevilliers notifications@github.com wrote:

By default the exchange is fanout and the queues are transient and messages non durable.

— Reply to this email directly or view it on GitHub.