Fix dead letter tests sharing the same topic

sobychacko · Sep 6, 2022 · a57c823 · a57c823
1 parent 25dcfab
commit a57c823
Showing 1 changed file with 2 additions and 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
@@ -294,14 +294,14 @@ void listen(String msg) {
 				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();
 			}
 
 		}