This closes #233
This commit is contained in:
commit
44b061d049
|
@ -694,7 +694,7 @@ public interface ActiveMQServerLogger extends BasicLogger {
|
||||||
|
|
||||||
@LogMessage(level = Logger.Level.WARN)
|
@LogMessage(level = Logger.Level.WARN)
|
||||||
@Message(id = 222095, value = "Connection failed with failedOver={0}", format = Message.Format.MESSAGE_FORMAT)
|
@Message(id = 222095, value = "Connection failed with failedOver={0}", format = Message.Format.MESSAGE_FORMAT)
|
||||||
void bridgeConnectionFailed(@Cause Exception e, Boolean failedOver);
|
void bridgeConnectionFailed(Boolean failedOver);
|
||||||
|
|
||||||
@LogMessage(level = Logger.Level.WARN)
|
@LogMessage(level = Logger.Level.WARN)
|
||||||
@Message(id = 222096, value = "Error on querying binding on bridge {0}. Retrying in 100 milliseconds", format = Message.Format.MESSAGE_FORMAT)
|
@Message(id = 222096, value = "Error on querying binding on bridge {0}. Retrying in 100 milliseconds", format = Message.Format.MESSAGE_FORMAT)
|
||||||
|
|
|
@ -571,7 +571,7 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
|
||||||
}
|
}
|
||||||
|
|
||||||
public void connectionFailed(final ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID) {
|
public void connectionFailed(final ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID) {
|
||||||
ActiveMQServerLogger.LOGGER.bridgeConnectionFailed(me, failedOver);
|
ActiveMQServerLogger.LOGGER.bridgeConnectionFailed(failedOver);
|
||||||
|
|
||||||
synchronized (connectionGuard) {
|
synchronized (connectionGuard) {
|
||||||
keepConnecting = true;
|
keepConnecting = true;
|
||||||
|
|
Loading…
Reference in New Issue