coderzc commented on code in PR #17092:
URL: https://github.com/apache/pulsar/pull/17092#discussion_r950585748
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java:
##
@@ -99,7 +100,7 @@ private long getCutoffTime() {
}
coderzc commented on code in PR #17092:
URL: https://github.com/apache/pulsar/pull/17092#discussion_r946806761
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java:
##
@@ -99,7 +100,7 @@ private long getCutoffTime() {
}
coderzc commented on code in PR #17092:
URL: https://github.com/apache/pulsar/pull/17092#discussion_r945464620
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java:
##
@@ -111,8 +111,10 @@ public boolean addMessage(long ledgerId, lo
coderzc commented on code in PR #17092:
URL: https://github.com/apache/pulsar/pull/17092#discussion_r945464620
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java:
##
@@ -111,8 +111,10 @@ public boolean addMessage(long ledgerId, lo
coderzc commented on code in PR #17092:
URL: https://github.com/apache/pulsar/pull/17092#discussion_r945464620
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java:
##
@@ -111,8 +111,10 @@ public boolean addMessage(long ledgerId, lo
coderzc commented on code in PR #17092:
URL: https://github.com/apache/pulsar/pull/17092#discussion_r945407900
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java:
##
@@ -111,8 +111,10 @@ public boolean addMessage(long ledgerId, lo