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) {