This is an automated email from the ASF dual-hosted git repository.
zhaocong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 8081ee26d8d [improve][broker][PIP-195] Make bucket merge operation
asynchronous (#19873)
add 329e80b847b [improve][broker] Clear delayed message when unsubscribe &
Make clear operation asynchronous (#19901)
No new revisions were added by this update.
Summary of changes:
.../broker/delayed/DelayedDeliveryTracker.java | 5 +-
.../delayed/InMemoryDelayedDeliveryTracker.java | 4 +-
.../pulsar/broker/delayed/bucket/Bucket.java | 21 +++++---
.../bucket/BucketDelayedDeliveryTracker.java | 63 +++++++++++++++-------
.../broker/delayed/bucket/ImmutableBucket.java | 57 ++++----------------
.../broker/delayed/bucket/MutableBucket.java | 7 +--
.../apache/pulsar/broker/service/Dispatcher.java | 4 +-
.../PersistentDispatcherMultipleConsumers.java | 23 +++++++-
.../service/persistent/PersistentSubscription.java | 11 +++-
.../broker/service/persistent/PersistentTopic.java | 46 ++++++++++++++--
.../bucket/BucketDelayedDeliveryTrackerTest.java | 7 ++-
.../persistent/BucketDelayedDeliveryTest.java | 59 ++++++++++++++++++++
12 files changed, 217 insertions(+), 90 deletions(-)
