From 6cdee9c18c50eee5cbe5d9cc0a3c37aefd330855 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 22 Sep 2022 19:16:59 -0400 Subject: [PATCH] Polish "Consolidate ACK/NACK calls in container" --- .../listener/DefaultPulsarMessageListenerContainer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java index ce2e6987..e462d5ed 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java @@ -386,7 +386,7 @@ public class DefaultPulsarMessageListenerContainer extends AbstractPulsarMess /** * Special scenario for batch error handling round1: messages m1,m2,...m10 are * received batch listener throws error on m3 goes through error handle flow and - * tracks m3 and sets messgeList to m3,m4..m10 round2: in retry mode, no new + * tracks m3 and sets messageList to m3,m4..m10 round2: in retry mode, no new * messages received If at this point all messages are handled successfully then * the normal flow will clear the handler state out. However, if the handler * throws an error again it will be one of 2 things... m3 or a subsequent message @@ -533,7 +533,7 @@ public class DefaultPulsarMessageListenerContainer extends AbstractPulsarMess @Override public void acknowledge(MessageId messageId) { - handleAckByMessageId(this.consumer, messageId); + AbstractAcknowledgement.handleAckByMessageId(this.consumer, messageId); } private static void handleAckByMessageId(Consumer consumer, MessageId messageId) {