Skip to content

Commit 50997af

Browse files
dao-junlhotari
authored andcommitted
[fix][broker] Fix BucketDelayedDeliveryTracker thread safety (#24014)
(cherry picked from commit a83dd86)
1 parent c8d8b6f commit 50997af

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -755,7 +755,7 @@ private boolean removeIndexBit(long ledgerId, long entryId) {
755755
.orElse(false);
756756
}
757757

758-
public boolean containsMessage(long ledgerId, long entryId) {
758+
public synchronized boolean containsMessage(long ledgerId, long entryId) {
759759
if (lastMutableBucket.containsMessage(ledgerId, entryId)) {
760760
return true;
761761
}

0 commit comments

Comments
 (0)