activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r762287 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network: DemandForwardingBridge.java DemandForwardingBridgeSupport.java
Date Mon, 06 Apr 2009 11:32:34 GMT
Author: gtully
Date: Mon Apr  6 11:32:33 2009
New Revision: 762287

URL: http://svn.apache.org/viewvc?rev=762287&view=rev
Log:
tidy up logging

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java?rev=762287&r1=762286&r2=762287&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java
Mon Apr  6 11:32:33 2009
@@ -55,7 +55,7 @@
             remoteBrokerName = remoteBrokerInfo.getBrokerName();
             if (localBrokerId != null) {
                 if (localBrokerId.equals(remoteBrokerId)) {
-                    LOG.info("Disconnecting loop back connection.");
+                    LOG.info(configuration.getBrokerName() + " disconnecting remote loop
back connection: " + remoteBrokerName);
                     // waitStarted();
                     ServiceSupport.dispose(this);
                 }
@@ -75,7 +75,7 @@
             localBrokerPath[0] = localBrokerId;
             if (remoteBrokerId != null) {
                 if (remoteBrokerId.equals(localBrokerId)) {
-                    LOG.info("Disconnecting loop back connection.");
+                    LOG.info(configuration.getBrokerName() + " disconnecting local loop back
connection.");
                     waitStarted();
                     ServiceSupport.dispose(this);
                 }

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?rev=762287&r1=762286&r2=762287&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Mon Apr  6 11:32:33 2009
@@ -558,7 +558,7 @@
             BrokerId[] path = destInfo.getBrokerPath();
             if (path != null && path.length >= networkTTL) {
                 if (LOG.isDebugEnabled()) {
-                    LOG.debug("Ignoring Subscription " + destInfo + " restricted to " + networkTTL
+ " network hops only");
+                    LOG.debug("Ignoring destination " + destInfo + " restricted to " + networkTTL
+ " network hops only");
                 }
                 return;
             }
@@ -566,7 +566,7 @@
                 // Ignore this consumer as it's a consumer we locally sent to
                 // the broker.
                 if (LOG.isDebugEnabled()) {
-                    LOG.debug("Ignoring sub " + destInfo + " already routed through this
broker once");
+                    LOG.debug("Ignoring destination " + destInfo + " already routed through
this broker once");
                 }
                 return;
             }



Mime
View raw message