From 41e2b873f22009a6c66023eb9a5990c7e9b79c07 Mon Sep 17 00:00:00 2001 From: Jiandong Date: Mon, 7 Apr 2025 21:03:06 +0800 Subject: [PATCH] Fix `polling-consumer.adoc` for the actual `AcknowledgmentCallback` Signed-off-by: Ma,Jiandong --- .../modules/ROOT/pages/polling-consumer.adoc | 20 +++++++++++++++---- 1 file changed, 16 insertions(+), 4 deletions(-) diff --git a/src/reference/antora/modules/ROOT/pages/polling-consumer.adoc b/src/reference/antora/modules/ROOT/pages/polling-consumer.adoc index c3ea08948c..884feaff17 100644 --- a/src/reference/antora/modules/ROOT/pages/polling-consumer.adoc +++ b/src/reference/antora/modules/ROOT/pages/polling-consumer.adoc @@ -68,15 +68,27 @@ When used with pollable message sources, the value of the header is an instance [source, java] ---- @FunctionalInterface -public interface AcknowledgmentCallback { +public interface AcknowledgmentCallback extends SimpleAcknowledgment { void acknowledge(Status status); - boolean isAcknowledged(); + @Override + default void acknowledge() { + acknowledge(Status.ACCEPT); + } - void noAutoAck(); + default boolean isAcknowledged() { + return false; + } - default boolean isAutoAck(); + + default void noAutoAck() { + throw new UnsupportedOperationException("You cannot disable auto acknowledgment with this implementation"); + } + + default boolean isAutoAck() { + return true; + } enum Status {