From 0b87aa1693d0008f760c245f22c1bc437cc52a9c Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Wed, 31 Aug 2022 18:05:54 -0400 Subject: [PATCH] Test debugging --- .../pulsar/core/ConsumerAcknowledgmentTests.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java b/spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java index 92697395..0f4d7d8d 100644 --- a/spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java +++ b/spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java @@ -37,6 +37,7 @@ import java.util.Set; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; +import org.apache.commons.logging.LogFactory; import org.apache.pulsar.client.api.Consumer; import org.apache.pulsar.client.api.Message; import org.apache.pulsar.client.api.Messages; @@ -45,6 +46,7 @@ import org.apache.pulsar.client.api.Schema; import org.junit.jupiter.api.Test; import org.springframework.beans.DirectFieldAccessor; +import org.springframework.core.log.LogAccessor; import org.springframework.pulsar.listener.Acknowledgement; import org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer; import org.springframework.pulsar.listener.PulsarAcknowledgingMessageListener; @@ -58,6 +60,8 @@ import org.springframework.util.Assert; */ class ConsumerAcknowledgmentTests extends AbstractContainerBaseTests { + protected final LogAccessor logger = new LogAccessor(LogFactory.getLog(this.getClass())); + @Test void testRecordAck() throws Exception { Map config = new HashMap<>(); @@ -154,7 +158,9 @@ class ConsumerAcknowledgmentTests extends AbstractContainerBaseTests { pulsarContainerProperties.setMessageListener((PulsarRecordMessageListener) (consumer, msg) -> { synchronized (lock) { latch.countDown(); + this.logger.error("Current count: " + latch.getCount()); if (latch.getCount() % 2 == 0) { + this.logger.error("Failing to acknowledge."); throw new RuntimeException("fail"); } }