parent
1abe155663
commit
073226d792
|
|
@ -465,9 +465,8 @@ public class StompSubProtocolHandler implements SubProtocolHandler, ApplicationE
|
||||||
}
|
}
|
||||||
|
|
||||||
if (StompCommand.ERROR.equals(command) && getErrorHandler() != null) {
|
if (StompCommand.ERROR.equals(command) && getErrorHandler() != null) {
|
||||||
Message<byte[]> enrichedMessage =
|
Message<byte[]> errorMessage = getErrorHandler().handleErrorMessageToClient(
|
||||||
MessageBuilder.createMessage((byte[]) message.getPayload(), accessor.getMessageHeaders());
|
MessageBuilder.createMessage((byte[]) message.getPayload(), accessor.getMessageHeaders()));
|
||||||
Message<byte[]> errorMessage = getErrorHandler().handleErrorMessageToClient(enrichedMessage);
|
|
||||||
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");
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue