diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java index 344daaee0a..405adf2a54 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java @@ -3674,7 +3674,7 @@ public class QueueImpl extends CriticalComponentImpl implements Queue { /** This will print errors and decide what to do with the errored consumer from the protocol layer. */ @Override public void errorProcessing(Consumer consumer, Throwable t, MessageReference reference) { - executor.execute(() -> errorProcessing(consumer, t, reference)); + executor.execute(() -> internalErrorProcessing(consumer, t, reference)); } private void internalErrorProcessing(Consumer consumer, Throwable t, MessageReference reference) {