From 082dd4ff4a16e3e9160ef686df20aea7b14ceaae Mon Sep 17 00:00:00 2001 From: penghui Date: Tue, 17 Nov 2020 15:02:02 +0800 Subject: [PATCH] Add more test case for BatchReceivePolicy. --- .../client/api/ConsumerBatchReceiveTest.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java index 5857221fbe114..bb2faecffb4c0 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerBatchReceiveTest.java @@ -170,6 +170,22 @@ public Object[][] batchReceivePolicyProvider() { .maxNumBytes(-100) .timeout(50, TimeUnit.MILLISECONDS) .build(), false, 30 + }, + // Only timeout present + { + BatchReceivePolicy.builder() + .maxNumMessages(0) + .maxNumBytes(0) + .timeout(50, TimeUnit.MILLISECONDS) + .build(), false, 30 + }, + // Only timeout present + { + BatchReceivePolicy.builder() + .maxNumMessages(-1) + .maxNumBytes(-1) + .timeout(50, TimeUnit.MILLISECONDS) + .build(), false, 30 } }; }