Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

tidy up logging 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@762287 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2009-04-06 11:32:33 +00:00
parent 1f4757b9d1
commit 21cd3e69c6
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java
View File

@ -55,7 +55,7 @@ public class DemandForwardingBridge extends DemandForwardingBridgeSupport {
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 @@ public class DemandForwardingBridge extends DemandForwardingBridgeSupport {
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);
}

4
activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
View File

@ -558,7 +558,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
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 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
// 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;
}