diff --git a/spring-websocket/src/main/java/org/springframework/web/socket/messaging/StompSubProtocolHandler.java b/spring-websocket/src/main/java/org/springframework/web/socket/messaging/StompSubProtocolHandler.java index 5be8839e0a..63602a8c42 100644 --- a/spring-websocket/src/main/java/org/springframework/web/socket/messaging/StompSubProtocolHandler.java +++ b/spring-websocket/src/main/java/org/springframework/web/socket/messaging/StompSubProtocolHandler.java @@ -465,9 +465,8 @@ public class StompSubProtocolHandler implements SubProtocolHandler, ApplicationE } if (StompCommand.ERROR.equals(command) && getErrorHandler() != null) { - Message enrichedMessage = - MessageBuilder.createMessage((byte[]) message.getPayload(), accessor.getMessageHeaders()); - Message errorMessage = getErrorHandler().handleErrorMessageToClient(enrichedMessage); + Message errorMessage = getErrorHandler().handleErrorMessageToClient( + MessageBuilder.createMessage((byte[]) message.getPayload(), accessor.getMessageHeaders())); if (errorMessage != null) { accessor = MessageHeaderAccessor.getAccessor(errorMessage, StompHeaderAccessor.class); Assert.state(accessor != null, "No StompHeaderAccessor");