[fix][broker] Fix BucketDelayedDeliveryTracker thread safety (apache#24014)

dao-jun · mukesh-ctds · commit 7e52b06fff4e · 2025-03-02T22:47:36.000+05:30
(cherry picked from commit a83dd86) (cherry picked from commit 4e39f70)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
@@ -754,7 +754,7 @@ private boolean removeIndexBit(long ledgerId, long entryId) {
                 .orElse(false);
     }
 
-    public boolean containsMessage(long ledgerId, long entryId) {
+    public synchronized boolean containsMessage(long ledgerId, long entryId) {
         if (lastMutableBucket.containsMessage(ledgerId, entryId)) {
             return true;
         }

Original file line number	Diff line number	Diff line change
`@@ -754,7 +754,7 @@ private boolean removeIndexBit(long ledgerId, long entryId) {`
`754`	`754`	`.orElse(false);`
`755`	`755`	`}`
`756`	`756`
`757`		`- public boolean containsMessage(long ledgerId, long entryId) {`
	`757`	`+ public synchronized boolean containsMessage(long ledgerId, long entryId) {`
`758`	`758`	`if (lastMutableBucket.containsMessage(ledgerId, entryId)) {`
`759`	`759`	`return true;`
`760`	`760`	`}`