This commit is contained in:
Clebert Suconic 2018-10-10 18:47:22 -04:00
commit 714a3f862e
2 changed files with 6 additions and 0 deletions

View File

@ -1968,4 +1968,8 @@ public interface ActiveMQServerLogger extends BasicLogger {
@LogMessage(level = Logger.Level.ERROR)
@Message(id = 224096, value = "Error setting up connection from {0} to {1}; protocol {2} not found in map: {3}", format = Message.Format.MESSAGE_FORMAT)
void failedToFindProtocolManager(String remoteAddress, String localAddress, String intendedProtocolManager, String protocolMap);
@LogMessage(level = Logger.Level.ERROR)
@Message(id = 224097, value = "Failed to start server", format = Message.Format.MESSAGE_FORMAT)
void failedToStartServer(@Cause Throwable t);
}

View File

@ -487,6 +487,8 @@ public class ActiveMQServerImpl implements ActiveMQServer {
SERVER_STATE originalState = state;
try {
internalStart();
} catch (Throwable t) {
ActiveMQServerLogger.LOGGER.failedToStartServer(t);
} finally {
if (originalState == SERVER_STATE.STOPPED) {
networkHealthCheck.setTimeUnit(TimeUnit.MILLISECONDS).setPeriod(configuration.getNetworkCheckPeriod()).