From d20259be1d6e4fed8f0e3cff67a98000df8fd2c2 Mon Sep 17 00:00:00 2001 From: Rossen Stoyanchev Date: Wed, 30 Apr 2014 11:01:18 -0400 Subject: [PATCH] Log STOMP ERROR frames 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 982e6e0951c..425f9a04c2b 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 @@ -550,18 +550,22 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler public void handleMessage(Message message) { StompHeaderAccessor headers = StompHeaderAccessor.wrap(message); + headers.setSessionId(this.sessionId); + if (SimpMessageType.HEARTBEAT.equals(headers.getMessageType())) { 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 == headers.getCommand()) { + logger.error("Received STOMP ERROR: " + message); + } if (StompCommand.CONNECTED == headers.getCommand()) { afterStompConnected(headers); } - headers.setSessionId(this.sessionId); message = MessageBuilder.withPayload(message.getPayload()).setHeaders(headers).build(); sendMessageToClient(message); }