Skip to content

Commit 339b270

Browse files
thetumbledlhotari
authored andcommitted
[fix][test] Add reconsumeLater call in RetryTopicTest#testRetryTopicWithMultiTopic. (#23857)
(cherry picked from commit 8015795)
1 parent 54a7efd commit 339b270

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: pulsar-broker/src/test/java/org/apache/pulsar/client/api/RetryTopicTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -464,7 +464,7 @@ public void testRetryTopicNameForCompatibility () throws Exception {
464464
}
465465

466466
/**
467-
* The test is disabled {@link https://github.com/apache/pulsar/issues/2647}.
467+
* Test retry topic with multiple topics
468468
* @throws Exception
469469
*/
470470
@Test
@@ -482,7 +482,6 @@ public void testRetryTopicWithMultiTopic() throws Exception {
482482
.subscriptionName("my-subscription")
483483
.subscriptionType(SubscriptionType.Shared)
484484
.enableRetry(true)
485-
.ackTimeout(1, TimeUnit.SECONDS)
486485
.deadLetterPolicy(DeadLetterPolicy.builder().maxRedeliverCount(maxRedeliveryCount).build())
487486
.receiverQueueSize(100)
488487
.subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
@@ -518,6 +517,7 @@ public void testRetryTopicWithMultiTopic() throws Exception {
518517
Message<byte[]> message = consumer.receive();
519518
log.info("consumer received message : {} {} - total = {}",
520519
message.getMessageId(), new String(message.getData()), ++totalReceived);
520+
consumer.reconsumeLater(message, 1, TimeUnit.SECONDS);
521521
} while (totalReceived < sendMessages * (maxRedeliveryCount + 1));
522522

523523
int totalInDeadLetter = 0;

0 commit comments

Comments
 (0)