Skip to content

Commit d20259b

Browse files
committed
Log STOMP ERROR frames at error level
Issue: SPR-11673
1 parent 6ca9210 commit d20259b

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -550,18 +550,22 @@ protected void sendMessageToClient(Message<?> message) {
550550
public void handleMessage(Message<byte[]> message) {
551551

552552
StompHeaderAccessor headers = StompHeaderAccessor.wrap(message);
553+
headers.setSessionId(this.sessionId);
554+
553555
if (SimpMessageType.HEARTBEAT.equals(headers.getMessageType())) {
554556
logger.trace("Received broker heartbeat");
555557
}
556558
else if (logger.isDebugEnabled()) {
557559
logger.debug("Received message from broker in session '" + this.sessionId + "'");
558560
}
561+
else if (logger.isErrorEnabled() && StompCommand.ERROR == headers.getCommand()) {
562+
logger.error("Received STOMP ERROR: " + message);
563+
}
559564

560565
if (StompCommand.CONNECTED == headers.getCommand()) {
561566
afterStompConnected(headers);
562567
}
563568

564-
headers.setSessionId(this.sessionId);
565569
message = MessageBuilder.withPayload(message.getPayload()).setHeaders(headers).build();
566570
sendMessageToClient(message);
567571
}

0 commit comments

Comments
 (0)