Configuring RabbitMQ Persistence

Updated on 2024-11-27 GMT+08:00

View PDF

By default, messages produced by RabbitMQ producers are stored in the memory. When a node breaks down or restarts, messages are lost. RabbitMQ can persist data during such events for exchanges, queues, and messages.

Persistence means writing messages in the memory to the disk to prevent them from being lost due to exceptions. However, if message persistence is enabled, RabbitMQ performance deteriorates because read and write operations are much slower in disks than in memory. Different from the lazy queue mechanism, a persisted message is stored in both the disk and memory. It is deleted from the memory only when the memory is insufficient.

NOTE:

Non-persistent queues and exchanges are lost after a restart.
Non-persistent messages are lost after a restart. (Messages that are sent to persistent queues or exchanges will not automatically become persistent.)
A message will be lost if the server restarts before the message persistence is complete.

Configuring Exchange Persistence

On the RabbitMQ management UI
Set durable to true in exchange creation, as shown in Figure 1.

Figure 1 Configuring exchange persistence (management UI)

Figure 2 shows a successful configuration.

Figure 2 Exchange persistence configured (management UI)
On the RabbitMQ console
Configure exchange persistence when creating an exchange, as shown in .

shows a successful configuration.

Configuring Queue Persistence

On the RabbitMQ management UI
Set durable to true in queue creation, as shown in Figure 3.

Figure 3 Configuring queue persistence (management UI)

Figure 4 shows a successful configuration.

Figure 4 Queue persistence configured (management UI)
On the RabbitMQ console
Configure queue persistence when creating a queue, as shown in .

shows a successful configuration.

Configuring Message Persistence

After configuring queue persistence, set MessageProperties to PERSISTENT_TEXT_PLAIN on the client to send persistent messages to the queue.

The following example shows how to configure message persistence on a Java client.

import com.rabbitmq.client.MessageProperties;
channel.basicPublish("", "my_queue",MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());

Parent topic: Advanced Features

Previous topic: Advanced Features

Next topic: Configuring RabbitMQ TTL

Feedback

Was this page helpful?

Helpful Not helpful

Provide feedback

Thank you very much for your feedback. We will continue working to improve the documentation.

The system is busy. Please try again later.

Which of the following issues have you encountered?

Content is inconsistent with the product UI

Unclear descriptions

Lack of examples or code

Incorrect steps

Can't find what I need

Lack of best practices

Feedback (optional)

0/500

Select at least one type of issue, and enter your comments or suggestions.

Enter a maximum of 500 characters.

Submit Cancel