From 21fd68150ac4dbc180b0f7d11c3a7086d8c24a69 Mon Sep 17 00:00:00 2001 From: Rossen Stoyanchev Date: Wed, 30 Apr 2014 11:12:32 -0400 Subject: [PATCH] Log ignored CONNECT messages at error level Issue: SPR-11673 --- .../simp/stomp/StompBrokerRelayMessageHandler.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java index 425f9a04c2..47f1fc0753 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java @@ -390,8 +390,11 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler if (sessionId == null || sessionId == SystemStompConnectionHandler.SESSION_ID) { throw new MessageDeliveryException("Message broker is not active."); } - if (logger.isDebugEnabled()) { - logger.debug("Message broker is not active. Ignoring message id=" + message.getHeaders().getId()); + if (SimpMessageType.CONNECT.equals(headers.getMessageType()) && logger.isErrorEnabled()) { + logger.error("Message broker is not active. Ignoring: " + message); + } + else if (logger.isDebugEnabled()) { + logger.debug("Message broker is not active. Ignoring: " + message); } return; }