Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Test debugging

Browse Source
This commit is contained in:
Soby Chacko
2022-08-31 18:05:54 -04:00
parent 34c4512dd8
commit 0b87aa1693
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-pulsar/src/test/java/org/springframework/pulsar/core/ConsumerAcknowledgmentTests.java
View File

@@ -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<String, Object> 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");
}
}