This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 31bae699ef38f22510f5ec26ed9d865558214037 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 25e3e2894da..862f1620c13 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 @@ -52,7 +52,7 @@ public final class NonPersistentDispatcherSingleActiveConsumer extends AbstractD } @Override - public void sendMessages(List<Entry> entries) { + public synchronized void sendMessages(List<Entry> entries) { Consumer currentConsumer = ACTIVE_CONSUMER_UPDATER.get(this); 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 2cad253f96e..90a944da7d3 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 @@ -127,7 +127,7 @@ public class NonPersistentStickyKeyDispatcherMultipleConsumers extends NonPersis }; @Override - public void sendMessages(List<Entry> entries) { + public synchronized void sendMessages(List<Entry> entries) { if (entries.isEmpty()) { return; }
