use addLong

fanjianye · fanjianye · commit ca48bb363027 · 2025-12-18T11:58:29.000+08:00
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java
@@ -130,7 +130,7 @@ public boolean addMessage(long ledgerId, long entryId, long deliverAt) {
                 .computeIfAbsent(timestamp, k -> new Long2ObjectRBTreeMap<>())
                 .computeIfAbsent(ledgerId, k -> new Roaring64Bitmap());
         if (!roaring64Bitmap.contains(entryId)) {
-            roaring64Bitmap.add(entryId);
+            roaring64Bitmap.addLong(entryId);
             delayedMessagesCount.incrementAndGet();
         }
 

Original file line number	Diff line number	Diff line change
`@@ -130,7 +130,7 @@ public boolean addMessage(long ledgerId, long entryId, long deliverAt) {`
`130`	`130`	`.computeIfAbsent(timestamp, k -> new Long2ObjectRBTreeMap<>())`
`131`	`131`	`.computeIfAbsent(ledgerId, k -> new Roaring64Bitmap());`
`132`	`132`	`if (!roaring64Bitmap.contains(entryId)) {`
`133`		`- roaring64Bitmap.add(entryId);`
	`133`	`+ roaring64Bitmap.addLong(entryId);`
`134`	`134`	`delayedMessagesCount.incrementAndGet();`
`135`	`135`	`}`
`136`	`136`