From 5dcd55b23b5dd43e5e7ef7241c15942ab8ceedb8 Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@gopivotal.com>
Date: Wed, 30 Apr 2014 11:11:43 -0400
Subject: [PATCH] Log ignored CONNECT messages at error level

Issue: SPR-11673
---
 .../simp/stomp/StompBrokerRelayMessageHandler.java          | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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 b9aec16ccf..3c897f9a05 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
@@ -400,7 +400,11 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler
 			if (sessionId == null || SystemStompConnectionHandler.SESSION_ID.equals(sessionId)) {
 				throw new MessageDeliveryException("Message broker is not active.");
 			}
-			if (logger.isDebugEnabled()) {
+			SimpMessageType messageType = SimpMessageHeaderAccessor.getMessageType(message.getHeaders());
+			if (messageType.equals(SimpMessageType.CONNECT) && 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;