Make the test fail

lhotari · Sep 13, 2024 · 1ff8c7c · 1ff8c7c
1 parent d3fcc0c
commit 1ff8c7c
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java
@@ -2430,7 +2430,6 @@ public void testOrderingAfterReconnects() throws Exception {
                 .subscriptionType(SubscriptionType.Key_Shared)
                 .receiverQueueSize(10)
                 .messageListener(messageHandler)
-                .startPaused(true)
                 .subscribe();
         // close and reconnect c1
         c1.close();
@@ -2456,7 +2455,6 @@ public void testOrderingAfterReconnects() throws Exception {
                 .subscribe();
 
         Thread.sleep(pauseTime);
-        c2.resume();
 
         System.out.println("readPosition: " + sub.getCursor().getReadPosition() + " numberOfMessagesInReplay: "
                 + dispatcher.getNumberOfMessagesInReplay());