Do not use timed receive in BrokerClientIntegrationTest.testUnsupport…

…edBatchMessageConsumer (apache#5333)
defncoder · Feb 11, 2020 · 83799f8 · 83799f8
1 parent 6eb7484
commit 83799f8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java
@@ -384,7 +384,7 @@ public void testUnsupportedBatchMessageConsumer(SubscriptionType subType) throws
 
         messageSet.clear();
         for (int i = 0; i < numMessagesPerBatch; i++) {
-            msg = consumer2.receive(1, TimeUnit.SECONDS);
+            msg = consumer2.receive();
             String receivedMessage = new String(msg.getData());
             log.debug("Received message: [{}]", receivedMessage);
             String expectedMessage = "my-batch-message-" + i;