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

Fix dead letter tests sharing the same topic

Browse Source
This commit is contained in:
Alexander Preuß
2022-09-06 19:50:17 +02:00
committed by Soby Chacko
parent 25dcfab607
commit a57c823a2a
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-pulsar/src/test/java/org/springframework/pulsar/listener/PulsarListenerTests.java
View File

@@ -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();
}
}