[activemq-artemis] branch new-logging updated: Logging changes on BridgeImpl I used on real debug, squash with everything else please

[clebertsuconic]

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

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


The following commit(s) were added to refs/heads/new-logging by this push:
     new 170cbd4f57 Logging changes on BridgeImpl I used on real debug, squash 
with everything else please
170cbd4f57 is described below

commit 170cbd4f576f82a50f2c9f414b1e247475299077
Author: Clebert Suconic <clebertsuco...@apache.org>
AuthorDate: Mon Sep 19 09:30:50 2022 -0400

    Logging changes on BridgeImpl I used on real debug, squash with everything 
else please
---
 .../artemis/core/server/cluster/impl/BridgeImpl.java         | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
index bb13fc7982..83454385dd 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
@@ -226,6 +226,9 @@ public class BridgeImpl implements Bridge, 
SessionFailureListener, SendAcknowled
 
    @Override
    public void onCreditsFlow(boolean blocked, ClientProducerCredits 
producerCredits) {
+      if (logger.isTraceEnabled()) {
+         logger.trace("Bridge {} received credits, with blocked = {}", 
this.getName(), blocked);
+      }
       this.blockedOnFlowControl = blocked;
       if (!blocked) {
          queue.deliverAsync();
@@ -560,27 +563,32 @@ public class BridgeImpl implements Bridge, 
SessionFailureListener, SendAcknowled
    @Override
    public HandleStatus handle(final MessageReference ref) throws Exception {
       if (filter != null && !filter.match(ref.getMessage())) {
+         if (logger.isTraceEnabled()) {
+            logger.trace("message reference {} is no match for bridge {}", 
ref, this.getName());
+         }
          return HandleStatus.NO_MATCH;
       }
 
       synchronized (this) {
          if (!active || !session.isWritable(this)) {
             if (logger.isDebugEnabled()) {
-               logger.debug(this + "::Ignoring reference on bridge as it is 
set to inactive ref=" + ref);
+               logger.debug(this + "::Ignoring reference on bridge as it is 
set to inactive ref {}, active = {}", ref, active);
             }
             return HandleStatus.BUSY;
          }
 
          if (blockedOnFlowControl) {
+            logger.debug("Bridge {} is blocked on flow control, cannot receive 
{}", getName(), ref);
             return HandleStatus.BUSY;
          }
 
          if (deliveringLargeMessage) {
+            logger.trace("Bridge {} is busy delivering a large message", 
this.getName());
             return HandleStatus.BUSY;
          }
 
          if (logger.isTraceEnabled()) {
-            logger.trace("Bridge " + this + " is handling reference=" + ref);
+            logger.trace("Bridge {} is handling reference {} ", ref);
          }
 
          ref.handled();