[fix][broker] Fix BucketDelayedDeliveryTracker thread safety (apache#…

…24014) (cherry picked from commit a83dd86) (cherry picked from commit 50997af)
datastax · Feb 27, 2025 · aa0c617 · aa0c617
1 parent e77a418
commit aa0c617
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...r/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java b/...r/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java
@@ -755,7 +755,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;
         }