File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
spring-messaging/src/main/java/org/springframework/messaging/simp/broker Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2002-2018 the original author or authors.
2
+ * Copyright 2002-2019 the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
@@ -289,7 +289,6 @@ public void stopInternal() {
289
289
@ Override
290
290
protected void handleMessageInternal (Message <?> message ) {
291
291
MessageHeaders headers = message .getHeaders ();
292
- SimpMessageType messageType = SimpMessageHeaderAccessor .getMessageType (headers );
293
292
String destination = SimpMessageHeaderAccessor .getDestination (headers );
294
293
String sessionId = SimpMessageHeaderAccessor .getSessionId (headers );
295
294
@@ -299,6 +298,7 @@ protected void handleMessageInternal(Message<?> message) {
299
298
return ;
300
299
}
301
300
301
+ SimpMessageType messageType = SimpMessageHeaderAccessor .getMessageType (headers );
302
302
if (SimpMessageType .MESSAGE .equals (messageType )) {
303
303
logMessage (message );
304
304
sendMessageToSubscribers (destination , message );
You can’t perform that action at this time.
0 commit comments