Fix Stomp Broker Relay ignoring destination prefixes in some cases

Toilal · rstoyanchev · commit 76dcde9e3107 · 2017-12-11T13:25:29.000-08:00
Issue: SPR-16265
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompHeaderAccessor.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompHeaderAccessor.java
@@ -197,7 +197,8 @@ public StompCommand updateStompCommandAsClientMessage() {
 		}
 		StompCommand command = getCommand();
 		if (command == null) {
-			setHeader(COMMAND_HEADER, StompCommand.SEND);
+			command = StompCommand.SEND
+			setHeader(COMMAND_HEADER, command);
 		}
 		else if (!command.equals(StompCommand.SEND)) {
 			throw new IllegalStateException("Unexpected STOMP command " + command);

Original file line number	Diff line number	Diff line change
`@@ -197,7 +197,8 @@ public StompCommand updateStompCommandAsClientMessage() {`
`197`	`197`	`}`
`198`	`198`	`StompCommand command = getCommand();`
`199`	`199`	`if (command == null) {`
`200`		`- setHeader(COMMAND_HEADER, StompCommand.SEND);`
	`200`	`+ command = StompCommand.SEND`
	`201`	`+ setHeader(COMMAND_HEADER, command);`
`201`	`202`	`}`
`202`	`203`	`else if (!command.equals(StompCommand.SEND)) {`
`203`	`204`	`throw new IllegalStateException("Unexpected STOMP command " + command);`