|
|
|
@ -400,8 +400,8 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler |
|
|
|
|
if (sessionId == null || SystemStompConnectionHandler.SESSION_ID.equals(sessionId)) { |
|
|
|
|
throw new MessageDeliveryException("Message broker is not active."); |
|
|
|
|
} |
|
|
|
|
if (logger.isTraceEnabled()) { |
|
|
|
|
logger.trace("Message broker is not active. Ignoring: " + message); |
|
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
|
logger.debug("Message broker is not active. Ignoring: " + message); |
|
|
|
|
} |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
@ -712,8 +712,8 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler |
|
|
|
|
|
|
|
|
|
if (!this.isStompConnected) { |
|
|
|
|
if (this.isRemoteClientSession) { |
|
|
|
|
if (logger.isTraceEnabled()) { |
|
|
|
|
logger.trace("Ignoring client message received " + message + |
|
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
|
logger.debug("Ignoring client message received " + message + |
|
|
|
|
(conn != null ? "before CONNECTED frame" : "after TCP connection closed")); |
|
|
|
|
} |
|
|
|
|
return EMPTY_TASK; |
|
|
|
|