This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit c472f17466dedeb4f6f07437305aa739fa2ae272 Author: Malla Sandeep <[email protected]> AuthorDate: Fri Jun 6 01:57:49 2025 +0530 [improve][broker] Added synchronized for sendMessages in Non-Persistent message dispatchers (#24386) (cherry picked from commit cb0fe5b0f65f09937e136eda9afeef13a7b08a03) --- .../nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java | 2 +- .../NonPersistentStickyKeyDispatcherMultipleConsumers.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java index ec83b4590b7..414e9235418 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java @@ -56,7 +56,7 @@ public final class NonPersistentDispatcherSingleActiveConsumer extends AbstractD } @Override - public void sendMessages(List<Entry> entries) { + public synchronized void sendMessages(List<Entry> entries) { Consumer currentConsumer = getActiveConsumer(); if (currentConsumer != null && currentConsumer.getAvailablePermits() > 0 && currentConsumer.isWritable()) { SendMessageInfo sendMessageInfo = SendMessageInfo.getThreadLocal(); diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumers.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumers.java index fb7bd22de94..e94bedd49a3 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumers.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumers.java @@ -135,7 +135,7 @@ public class NonPersistentStickyKeyDispatcherMultipleConsumers extends NonPersis }; @Override - public void sendMessages(List<Entry> entries) { + public synchronized void sendMessages(List<Entry> entries) { if (entries.isEmpty()) { return; }
