This commit is contained in:
Clebert Suconic 2018-03-26 10:32:53 -04:00
commit 5a39446561
2 changed files with 4 additions and 3 deletions

View File

@ -1927,4 +1927,7 @@ public interface ActiveMQServerLogger extends BasicLogger {
@Message(id = 224090, value = "This node is not configured for Quorum Voting, all nodes must be configured for HA", format = Message.Format.MESSAGE_FORMAT) @Message(id = 224090, value = "This node is not configured for Quorum Voting, all nodes must be configured for HA", format = Message.Format.MESSAGE_FORMAT)
void noVoteHandlerConfigured(); void noVoteHandlerConfigured();
@LogMessage(level = Logger.Level.WARN)
@Message(id = 224091, value = "Bridge {0} is unable to connect to destination. Retrying", format = Message.Format.MESSAGE_FORMAT)
void errorConnectingBridgeRetry(Bridge bridge);
} }

View File

@ -929,9 +929,7 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
scheduleRetryConnectFixedTimeout(this.retryInterval); scheduleRetryConnectFixedTimeout(this.retryInterval);
return; return;
} else { } else {
if (logger.isDebugEnabled()) { ActiveMQServerLogger.LOGGER.errorConnectingBridgeRetry(this);
logger.debug("Bridge " + this + " is unable to connect to destination. Retrying", e);
}
scheduleRetryConnect(); scheduleRetryConnect();
} }