@ -185,7 +185,9 @@ public class StompHeaderAccessor extends SimpMessageHeaderAccessor {
@@ -185,7 +185,9 @@ public class StompHeaderAccessor extends SimpMessageHeaderAccessor {
Assert.state(SimpMessageType.MESSAGE.equals(getMessageType()),"Unexpected message type "+getMessage());
if(getMessageType()!=SimpMessageType.MESSAGE){
thrownewIllegalStateException("Unexpected message type "+getMessageType());
}
if(getCommand()==null){
setHeader(COMMAND_HEADER,StompCommand.SEND);
}
@ -196,7 +198,9 @@ public class StompHeaderAccessor extends SimpMessageHeaderAccessor {
@@ -196,7 +198,9 @@ public class StompHeaderAccessor extends SimpMessageHeaderAccessor {
}
publicvoidupdateStompCommandAsServerMessage(){
Assert.state(SimpMessageType.MESSAGE.equals(getMessageType()),"Unexpected message type "+getMessage());
if(getMessageType()!=SimpMessageType.MESSAGE){
thrownewIllegalStateException("Unexpected message type "+getMessageType());
@ -434,7 +438,10 @@ public class StompHeaderAccessor extends SimpMessageHeaderAccessor {
@@ -434,7 +438,10 @@ public class StompHeaderAccessor extends SimpMessageHeaderAccessor {
}
privateStringappendPayload(Objectpayload){
Assert.isInstanceOf(byte[].class,payload);
if(payload.getClass()!=byte[].class){
thrownewIllegalStateException(
"Expected byte array payload but got: "+ClassUtils.getQualifiedName(payload.getClass()));