From a57c823a2ad69ff9f80c8c14d2a422f83d3b1b5f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Alexander=20Preu=C3=9F?= Date: Tue, 6 Sep 2022 19:50:17 +0200 Subject: [PATCH] Fix dead letter tests sharing the same topic --- .../springframework/pulsar/listener/PulsarListenerTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-pulsar/src/test/java/org/springframework/pulsar/listener/PulsarListenerTests.java b/spring-pulsar/src/test/java/org/springframework/pulsar/listener/PulsarListenerTests.java index 842f8c2f..414fd1c0 100644 --- a/spring-pulsar/src/test/java/org/springframework/pulsar/listener/PulsarListenerTests.java +++ b/spring-pulsar/src/test/java/org/springframework/pulsar/listener/PulsarListenerTests.java @@ -294,14 +294,14 @@ public class PulsarListenerTests extends AbstractContainerBaseTests { throw new RuntimeException("fail " + msg); } - @PulsarListener(id = "dlqListener", subscriptionType = "dlqListenerSubscription", topics = "dlq-topic") + @PulsarListener(id = "dlqListener", subscriptionType = "dlqListenerSubscription", topics = "dlpt-dlq-topic") void listenDlq(String msg) { dlqLatch.countDown(); } @Bean DeadLetterPolicy deadLetterPolicy() { - return DeadLetterPolicy.builder().maxRedeliverCount(1).deadLetterTopic("dlq-topic").build(); + return DeadLetterPolicy.builder().maxRedeliverCount(1).deadLetterTopic("dlpt-dlq-topic").build(); } }