You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2009/04/06 13:32:34 UTC
svn commit: r762287 - in
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network:
DemandForwardingBridge.java DemandForwardingBridgeSupport.java
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;
}