You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cs...@apache.org on 2018/09/04 10:53:27 UTC
activemq git commit: Revert "AMQ-7004 - Improved logging in Failover
Transport"
Repository: activemq
Updated Branches:
refs/heads/master 1e31df980 -> 0b71b06ac
Revert "AMQ-7004 - Improved logging in Failover Transport"
This reverts commit 7974e8c0991dd0bcf2e226ea9b54ff8d740acfc8.
This caused problems with too much logging so reverting
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/0b71b06a
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/0b71b06a
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/0b71b06a
Branch: refs/heads/master
Commit: 0b71b06ac81f4192ac752e6fdbfa0b84eb635052
Parents: 1e31df9
Author: Christopher L. Shannon (cshannon) <ch...@gmail.com>
Authored: Tue Sep 4 06:53:00 2018 -0400
Committer: Christopher L. Shannon (cshannon) <ch...@gmail.com>
Committed: Tue Sep 4 06:53:00 2018 -0400
----------------------------------------------------------------------
.../org/apache/activemq/transport/failover/FailoverTransport.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/0b71b06a/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 caf14f4..9c24828 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,7 +1057,6 @@ 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 {
@@ -1287,7 +1286,6 @@ 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);
}
}
}