Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-03-08 10:19:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

This closes #3705

Browse Source
This commit is contained in:
Clebert Suconic 2021-08-20 16:33:21 -04:00
commit eb73709a1a
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
View File

@ -1902,8 +1902,12 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
}
if (AuditLogger.isMessageLoggingEnabled()) {
ServerSession session = server.getSessionByID(consumer.getSessionID());
AuditLogger.coreAcknowledgeMessage(session.getRemotingConnection().getAuditSubject(), session.getRemotingConnection().getRemoteAddress(), getName().toString(), ref.getMessage().toString());
ServerSession session = null;
// it's possible for the consumer to be null (e.g. acking the message administratively)
if (consumer != null) {
session = server.getSessionByID(consumer.getSessionID());
}
AuditLogger.coreAcknowledgeMessage(session == null ? null : session.getRemotingConnection().getAuditSubject(), session == null ? null : session.getRemotingConnection().getRemoteAddress(), getName().toString(), ref.getMessage().toString());
}
if (server != null && server.hasBrokerMessagePlugins()) {
server.callBrokerMessagePlugins(plugin -> plugin.messageAcknowledged(ref, reason, consumer));