From d52f07aa1b83208dd84b65d2a4ba724b3a0227ff Mon Sep 17 00:00:00 2001 From: Rossen Stoyanchev Date: Wed, 30 Apr 2014 11:00:27 -0400 Subject: [PATCH] Log STOMP ERROR frames 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 7421fbdbb0..b9aec16ccf 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 @@ -583,20 +583,23 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler StompHeaderAccessor headerAccessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class); + headerAccessor.setSessionId(this.sessionId); + if (headerAccessor.isHeartbeat()) { logger.trace("Received broker heartbeat"); } else if (logger.isDebugEnabled()) { logger.debug("Received message from broker in session '" + this.sessionId + "'"); } + else if (logger.isErrorEnabled() && StompCommand.ERROR == headerAccessor.getCommand()) { + logger.error("Received STOMP ERROR: " + message); + } if (StompCommand.CONNECTED == headerAccessor.getCommand()) { afterStompConnected(headerAccessor); } - headerAccessor.setSessionId(this.sessionId); headerAccessor.setImmutable(); - sendMessageToClient(message); }