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

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


The following commit(s) were added to refs/heads/main by this push:
     new 42ddf99ca8 ARTEMIS-4557 fix audit logging
42ddf99ca8 is described below

commit 42ddf99ca8846218ee7b49d97a4f5087318c15e3
Author: Justin Bertram <[email protected]>
AuthorDate: Wed Jan 10 09:07:29 2024 -0600

    ARTEMIS-4557 fix audit logging
---
 .../main/java/org/apache/activemq/artemis/logs/AuditLogger.java    | 7 +++++++
 .../artemis/core/management/impl/ClusterConnectionControlImpl.java | 2 +-
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/logs/AuditLogger.java
 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/logs/AuditLogger.java
index 62fa7ca62e..ffb2535150 100644
--- 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/logs/AuditLogger.java
+++ 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/logs/AuditLogger.java
@@ -2675,4 +2675,11 @@ public interface AuditLogger {
    @LogMessage(id = 601771, value = "User {} is getting name on target 
resource: {}", level = LogMessage.Level.INFO)
    void getCurrentTimeMillis(Object source);
 
+   static void getProducerWindowSize(Object source) {
+      BASE_LOGGER.getProducerWindowSize(getCaller(), source);
+   }
+
+   @LogMessage(id = 601772, value = "User {} is getting producerWindowSize on 
target resource: {}", level = LogMessage.Level.INFO)
+   void getProducerWindowSize(String user, Object source);
+
 }
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/ClusterConnectionControlImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/ClusterConnectionControlImpl.java
index fed58b6d65..4b21cb9054 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/ClusterConnectionControlImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/ClusterConnectionControlImpl.java
@@ -324,7 +324,7 @@ public class ClusterConnectionControlImpl extends 
AbstractControl implements Clu
    @Override
    public long getProducerWindowSize() {
       if (AuditLogger.isBaseLoggingEnabled()) {
-         AuditLogger.getTopology(this.clusterConnection);
+         AuditLogger.getProducerWindowSize(this.clusterConnection);
       }
       clearIO();
       try {

Reply via email to