This is an automated email from the ASF dual-hosted git repository.
zhangmingao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new c4bd7ae15a1 [fix][test] entry filter makes no sense (#17170)
c4bd7ae15a1 is described below
commit c4bd7ae15a1e37075fb5a0b3b4636591ed2462c8
Author: gaozhangmin <[email protected]>
AuthorDate: Mon Aug 22 14:25:04 2022 +0800
[fix][test] entry filter makes no sense (#17170)
* [fix][test] entry filter makes no sense because trackDelayedDelivery
always return true
* apply comments
Co-authored-by: gavingaozhangmin <[email protected]>
---
.../org/apache/pulsar/broker/service/AbstractBaseDispatcherTest.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractBaseDispatcherTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractBaseDispatcherTest.java
index 1f9153c3ae7..d89738869a8 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractBaseDispatcherTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractBaseDispatcherTest.java
@@ -214,8 +214,7 @@ public class AbstractBaseDispatcherTest {
@Override
public boolean trackDelayedDelivery(long ledgerId, long entryId,
MessageMetadata msgMetadata) {
- //for test.
- return true;
+ return msgMetadata.hasDeliverAtTime();
}
@Override