This closes #442
This commit is contained in:
commit
2f0ecb3065
|
@ -886,7 +886,7 @@ public interface ActiveMQServerLogger extends BasicLogger {
|
||||||
|
|
||||||
@LogMessage(level = Logger.Level.WARN)
|
@LogMessage(level = Logger.Level.WARN)
|
||||||
@Message(id = 222137, value = "Unable to announce backup, retrying", format = Message.Format.MESSAGE_FORMAT)
|
@Message(id = 222137, value = "Unable to announce backup, retrying", format = Message.Format.MESSAGE_FORMAT)
|
||||||
void errorAnnouncingBackup();
|
void errorAnnouncingBackup(@Cause Throwable e);
|
||||||
|
|
||||||
@LogMessage(level = Logger.Level.WARN)
|
@LogMessage(level = Logger.Level.WARN)
|
||||||
@Message(id = 222138, value = "Local Member is not set at on ClusterConnection {0}", format = Message.Format.MESSAGE_FORMAT)
|
@Message(id = 222138, value = "Local Member is not set at on ClusterConnection {0}", format = Message.Format.MESSAGE_FORMAT)
|
||||||
|
|
|
@ -259,7 +259,7 @@ public class BackupManager implements ActiveMQComponent {
|
||||||
return;
|
return;
|
||||||
if (stopping)
|
if (stopping)
|
||||||
return;
|
return;
|
||||||
ActiveMQServerLogger.LOGGER.errorAnnouncingBackup();
|
ActiveMQServerLogger.LOGGER.errorAnnouncingBackup(e);
|
||||||
|
|
||||||
scheduledExecutor.schedule(new Runnable() {
|
scheduledExecutor.schedule(new Runnable() {
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue