This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new d9aacec  ARTEMIS-1975 Fixing Typo on QueueImpl::errorProcessing
d9aacec is described below

commit d9aacec8bb4a3945af38ba8c23a1b5dad5261903
Author: Clebert Suconic <[email protected]>
AuthorDate: Thu Apr 16 10:52:45 2020 -0400

    ARTEMIS-1975 Fixing Typo on QueueImpl::errorProcessing
---
 .../java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 344daae..405adf2 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) {

Reply via email to