Skip to content

Commit

Permalink
[fix][broker]Fix NonPersistentDispatcherMultipleConsumers ArrayIndexO…
Browse files Browse the repository at this point in the history
…utOfBoundsException (#21856)
  • Loading branch information
Technoboy- committed Jan 8, 2024
1 parent 1743cbb commit f7b768d
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,7 @@ public RedeliveryTracker getRedeliveryTracker() {
}

@Override
public void sendMessages(List<Entry> entries) {
public synchronized void sendMessages(List<Entry> entries) {
Consumer consumer = TOTAL_AVAILABLE_PERMITS_UPDATER.get(this) > 0 ? getNextConsumer() : null;
if (consumer != null) {
SendMessageInfo sendMessageInfo = SendMessageInfo.getThreadLocal();
Expand Down

0 comments on commit f7b768d

Please sign in to comment.