Skip to content
This repository was archived by the owner on Sep 26, 2025. It is now read-only.

Commit d5a41ea

Browse files
committed
document AcknowledgableDelivery ack and nack methods API
1 parent 2f37e3d commit d5a41ea

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/main/java/reactor/rabbitmq/AcknowledgableDelivery.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ public AcknowledgableDelivery(Delivery delivery, Channel channel, BiConsumer<Rec
5252
* Acknowledges this message if it has not been previously acked or nacked.
5353
* Subsequent calls to the method for previously acknowledged message will not produce errors and will simply
5454
* return instantly.
55+
* In case of connection failure, {@link AcknowledgableDelivery#exceptionHandler} is executed.
5556
* @param multiple Defines whether all messages up to and including the supplied delivery tag should be
5657
* acknowledged or not.
5758
*/
@@ -69,6 +70,7 @@ public void ack(boolean multiple) {
6970
* Acknowledges this message if it has not been previously acked or nacked.
7071
* Subsequent calls to the method for previously acknowledged message will not produce errors and will simply
7172
* return instantly.
73+
* In case of connection failure, {@link AcknowledgableDelivery#exceptionHandler} is executed.
7274
*/
7375
public void ack() {
7476
ack(false);
@@ -78,6 +80,7 @@ public void ack() {
7880
* Rejects this message if it has not been previously acked or nacked.
7981
* Subsequent calls to the method for previously acknowledged or rejected message will not produce errors and
8082
* will simply return instantly.
83+
* In case of connection failure, {@link AcknowledgableDelivery#exceptionHandler} is executed.
8184
* @param multiple Defines whether all messages up to and including the supplied delivery tag should be
8285
* rejected or not.
8386
* @param requeue Defines if the message should be added to the queue again instead of being discarded.
@@ -96,6 +99,7 @@ public void nack(boolean multiple, boolean requeue) {
9699
* Rejects this message if it has not been previously acked or nacked.
97100
* Subsequent calls to the method for previously acknowledged or rejected message will not produce errors and
98101
* will simply return instantly.
102+
* In case of connection failure, {@link AcknowledgableDelivery#exceptionHandler} is executed.
99103
*/
100104
public void nack(boolean requeue) {
101105
nack(false, requeue);

0 commit comments

Comments
 (0)