Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-16 23:16:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

AMQ-4706 - ensure we log the first warn and include the failure reason

Browse Source
This commit is contained in:
gtully 2018-07-05 17:34:30 +01:00
parent d8c939a4bd
commit 2b64b7b04f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
View File

@ -1096,9 +1096,9 @@ public class FailoverTransport implements CompositeTransport {
}
int warnInterval = getWarnAfterReconnectAttempts();
if (warnInterval > 0 && (connectFailures % warnInterval) == 0) {
LOG.warn("Failed to connect to {} after: {} attempt(s) continuing to retry.",
uris, connectFailures);
if (warnInterval > 0 && (connectFailures == 1 || (connectFailures % warnInterval) == 0)) {
LOG.warn("Failed to connect to {} after: {} attempt(s) with {}, continuing to retry.",
uris, connectFailures, (failure == null ? "?" : failure.getLocalizedMessage()));
}
}