How long a RabbitMQ Message stays alive without Subscribers?

Question

I am creating a simple Publisher/Subscriber using MassTransit and RabbitMQ. The Publisher has the following code to initialize the bus:

/** create the bus */
var bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    var host = cfg.Host(new Uri("rabbitmq://localhost/"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });
});

/** start the bus and publish */
bus.Start();
bus.Publish<IPersonLogin>(new {FirstName = "John", LastName = "Smith"});

And the Subscriber has this code for initialization:

var bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    var host = cfg.Host(new Uri("rabbitmq://localhost/"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });

    cfg.ReceiveEndpoint(host, "person_login", e =>
    {
        e.Consumer<PersonLoginConsumer>();
    });
});

If I shut-down the Subscriber and publish 2 messages, the messages are not lost and as soon as the Subscriber comes back to life the Messages are processed.

So my questions are:

How do I ensure that a Message stays in the Queue of RabbitMQ until one Subscriber comes up and pick it up?
What happen if the Server is reboot and some Messages were not processed by any Subscriber, do they get lost or do they get processed as soon as the Subscriber come alive after reboot?
Is this the correct pattern to ensure that every single message is processed or should I use a different strategy?

Derick Bailey Derick Bailey · Accepted Answer · 2016-01-13T01:30:34

by default, any message sitting in a queue will remain there until one of three things happens:

the message is consumed
the message "time to live" expires (default is to live forever)
the server crashes or restarts

if you have a queue full of messages, the messages will generally stick around until one of those three things happens. hopefully you will have your consumers online soon enough that you can consume the messages and process them.

you would only set a time to live (ttl) if you want messages to be automatically deleted after a period of time (assuming they are not consumed first)

for crashes... a message can survive a crash / restart if you make the message persistent to disk. there's still a chance that the message will be lost if the server crashes before the message is routed from the exchange to the queue, though.

How long a RabbitMQ Message stays alive without Subscribers?

2 Answers