|
|
|
@ -466,7 +466,7 @@ public class StompSubProtocolHandler implements SubProtocolHandler, ApplicationE |
|
|
|
|
|
|
|
|
|
|
|
if (StompCommand.ERROR.equals(command) && getErrorHandler() != null) { |
|
|
|
if (StompCommand.ERROR.equals(command) && getErrorHandler() != null) { |
|
|
|
Message<byte[]> errorMessage = getErrorHandler().handleErrorMessageToClient( |
|
|
|
Message<byte[]> errorMessage = getErrorHandler().handleErrorMessageToClient( |
|
|
|
MessageBuilder.createMessage((byte[]) message.getPayload(), accessor.getMessageHeaders())); |
|
|
|
MessageBuilder.createMessage(payload, accessor.getMessageHeaders())); |
|
|
|
if (errorMessage != null) { |
|
|
|
if (errorMessage != null) { |
|
|
|
accessor = MessageHeaderAccessor.getAccessor(errorMessage, StompHeaderAccessor.class); |
|
|
|
accessor = MessageHeaderAccessor.getAccessor(errorMessage, StompHeaderAccessor.class); |
|
|
|
Assert.state(accessor != null, "No StompHeaderAccessor"); |
|
|
|
Assert.state(accessor != null, "No StompHeaderAccessor"); |
|
|
|
|