You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2014/02/12 14:29:41 UTC
git commit: improve failover transport failure message to include
client port,
which makes will make it easier to debug things in multi-connection clients
Updated Branches:
refs/heads/trunk 973580603 -> 084d606d8
improve failover transport failure message to include client port, which makes will make it easier to debug things in multi-connection clients
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/084d606d
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/084d606d
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/084d606d
Branch: refs/heads/trunk
Commit: 084d606d897cc625836a82e6eeaaa2e80cad5477
Parents: 9735806
Author: Dejan Bosanac <de...@nighttale.net>
Authored: Wed Feb 12 14:29:23 2014 +0100
Committer: Dejan Bosanac <de...@nighttale.net>
Committed: Wed Feb 12 14:29:23 2014 +0100
----------------------------------------------------------------------
.../org/apache/activemq/transport/failover/FailoverTransport.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/084d606d/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
----------------------------------------------------------------------
diff --git a/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java b/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
index e9ce12c..2ea1b37 100755
--- a/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
+++ b/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
@@ -257,7 +257,7 @@ public class FailoverTransport implements CompositeTransport {
if (canReconnect()) {
reconnectOk = true;
}
- LOG.warn("Transport (" + transport.getRemoteAddress() + ") failed, reason: " + e
+ LOG.warn("Transport (" + transport + ") failed, reason: " + e
+ (reconnectOk ? "," : ", not") + " attempting to automatically reconnect");
initialized = false;