捕鱼机龙腾四海

書名： RabbitMQ Cookbook
作者名： Sigismondo Boschi Gabriele Santomaggio
本章字?jǐn)?shù)： 334字
更新時間： 2021-07-19 18:52:50

How to let queues expire

In this third case, the TTL is not related to messages anymore, but to queues. This case is a perfect fit to manage server restarts and updates. The RabbitMQ drops the queue as soon as the TTL has elapsed, that is, after the last consumer has stopped consuming messages.

As in the previous TTL-related recipes, you can find the Producer.java, Consumer.java, and GetOne.java files in Chapter02/Recipe03/Java/src/rmqexample.

Getting ready

To use this recipe, we need to set up the Java development environment as indicated in the Introduction section of Chapter 1, Working with AMQP.

How to do it...

As in the previous example, the extension regards only Consumer.java:

Create or declare the exchange using the following code:
```
channel.exchangeDeclare(exchange, "direct", false);
```

Create or declare the queue, specifying a 30,000 milliseconds timeout to the x-expires optional argument as follows:

Map<String, Object> arguments = new HashMap<String, Object>();
arguments.put("x-expires", 30000);
channel.queueDeclare(queue, false, false, false, arguments);

Bind the queue to the exchange where messages are going to come from as follows:
```
channel.queueBind(queue, exchange, routingKey);
```

How it works...

When we run either the Consumer.java or GetOne.java file, the timed queue is created and until there is a consumer attached to the queue or we call channel.basicGet(), it will continue to exist.

Only when we stop both the operations for at least 30 seconds, the queue is dropped and all the messages that it contains are lost.

Note

The queue is dropped independently from the fact that there are producers publishing messages to it or not.

In the course of the experiments, we can monitor the RabbitMQ queue status issuing rabbitmqctl list_queues and see this happening.

So, we can imagine a scenario where we have a statistics analysis program that needs to be restarted for an update of the code itself. It will restart without losing any messages, since its named queues will have a longer timeout. Alternatively, if we stop it, its queues will be deleted after the given TTL and worthless messages won't be stored at all.

官术网_书友最值得收藏!

RabbitMQ Cookbook

How to let queues expire

Getting ready

How to do it...

How it works...

Note