Skip to content

Commit c4bd7ae

Browse files
gaozhangmingavingaozhangmin
and
gavingaozhangmin
authored
[fix][test] entry filter makes no sense (apache#17170)
* [fix][test] entry filter makes no sense because trackDelayedDelivery always return true * apply comments Co-authored-by: gavingaozhangmin <gavingaozhangmin@didiglobal.com>
1 parent 8159368 commit c4bd7ae

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractBaseDispatcherTest.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -214,8 +214,7 @@ protected boolean isConsumersExceededOnSubscription() {
214214

215215
@Override
216216
public boolean trackDelayedDelivery(long ledgerId, long entryId, MessageMetadata msgMetadata) {
217-
//for test.
218-
return true;
217+
return msgMetadata.hasDeliverAtTime();
219218
}
220219

221220
@Override

0 commit comments

Comments
 (0)