Repository: activemq Updated Branches: refs/heads/activemq-5.15.x ed23aca30 -> 83d4aab2d
AMQ-7004 - Improved logging in Failover Transport (cherry picked from commit 7974e8c0991dd0bcf2e226ea9b54ff8d740acfc8) Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/83d4aab2 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/83d4aab2 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/83d4aab2 Branch: refs/heads/activemq-5.15.x Commit: 83d4aab2d16163da7d896af3d76bc3762b84e28a Parents: ed23aca Author: Christopher L. Shannon (cshannon) <[email protected]> Authored: Mon Jul 30 07:56:33 2018 -0400 Committer: Christopher L. Shannon (cshannon) <[email protected]> Committed: Mon Jul 30 07:57:39 2018 -0400 ---------------------------------------------------------------------- .../org/apache/activemq/transport/failover/FailoverTransport.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/83d4aab2/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 655f143..fe570af 100644 --- 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 @@ -1057,6 +1057,7 @@ public class FailoverTransport implements CompositeTransport { return false; } catch (Exception e) { failure = e; + LOG.error("Connect fail to: {}, error message: {}", uri, e.getMessage()); LOG.debug("Connect fail to: {}, reason: {}", uri, e); if (transport != null) { try { @@ -1286,6 +1287,7 @@ public class FailoverTransport implements CompositeTransport { for (URI uri : updatedURIs) { if (uri != null && !updated.contains(uri)) { updated.add(uri); + LOG.info("Adding new URI to transport: {}", uri); } } }
