- RabbitMQ Cookbook
- Sigismondo Boschi Gabriele Santomaggio
- 503字
- 2021-07-19 18:52:48
Guaranteeing message processing
In this example we will show how to use the explicit acknowledgment, the so-called ack, while consuming messages.
A message is stored in a queue until one consumer gets the message and sends the ack back to the broker.
The ack can be either implicit or explicit. In the previous examples we have used theimplicit ack.
In order to view this example in action, you can run the publisher from the Producing messages recipe and the consumer who gets the message, which you can find in the book archive at Chapter01/Recipe09/Java_9/.
Getting ready
To use this recipe we need to set up the Java development environment as indicated in the Introduction section.
How to do it…
In order to guarantee that the messages have been acknowledged by the consumer after processing them, you can perform the following steps:
- Declare a queue:
channel.queueDeclare(myQueue, true, false, false,null);
- Bind the consumer to the queue, specifying
falsefor theautoAckparameter ofbasicConsume():ActualConsumer consumer = new ActualConsumer(channel); boolean autoAck = false; // n.b. channel.basicConsume(MyQueue, autoAck, consumer);
- Consume a message and send the
ack:public void handleDelivery(String consumerTag,Envelope envelope, BasicPropertiesproperties,byte[] body) throws java.io.IOException { String message = new String(body); this.getChannel().basicAck(envelope.getDeliveryTag(),false);
How it works…
After we created the queue (step 1), we added the consumer to the queue and defined the ack behavior (step 2).
The parameter autoack = false informs the RabbitMQ client API that we are going to send explicit ack ourselves.
After we have got a message from the queue, we must acknowledge to RabbitMQ that we have received and properly processed the message calling channel.basicAck()(step 3). The message will be removed from the queue only when RabbitMQ receives the ack.
Tip
If you don't send the ack back, the consumer continues to fetch subsequent messages; however, when you disconnect the consumer, all the messages will still be in the queue. Messages are not consumed until RabbitMQ receives the corresponding ack. Try to comment out the basicAck() call in the example to experiment this behavior.
The method channel.basicAck() has two parameters:
deliveryTagmultiple
The deliveryTag parameter is a value assigned by the server to the message, which you can retrieve using delivery.getEnvelope().getDeliveryTag().
If multiple is set to false the client acknowledges only the message of the deliveryTag parameter, otherwise the client acknowledges all the messages until this last one. This flag allows us to optimize consuming messages by sending ack to RabbitMQ on a block of messages instead of for each one.
Calling channel.basicAck(0,true) all the unacknowledged messages get acknowledged; the 0 stands for "all the messages".
Furthermore, calling channel.basicAck(0,false) raises an exception.
There's more…
In the next chapter we will discuss the basicReject() method. This method is a RabbitMQ extension that allows further flexibility.
See also
The Distributing messages to many consumers recipe is a real example that explains better explicit ack use.
- C語言程序設計（第2 版）
- SQL基礎教程（視頻教學版）
- TradeStation交易應用實踐：量化方法構建贏家策略（原書第2版）
- Visual FoxPro程序設計
- Highcharts Cookbook
- Scala for Machine Learning（Second Edition）
- Node學習指南（第2版）
- Android嵌入式系統程序開發：基于Cortex-A8（第2版）
- 3ds Max印象 電視欄目包裝動畫與特效制作
- 自學Python：編程基礎、科學計算及數據分析（第2版）
- PrimeFaces Blueprints
- Learning Redux
- Tkinter GUI Programming by Example
- Selenium WebDriver自動化測試完全指南
- Yii框架深度剖析