|
|
|
|
@ -36,6 +36,7 @@ import org.springframework.messaging.GenericMessage;
@@ -36,6 +36,7 @@ import org.springframework.messaging.GenericMessage;
|
|
|
|
|
import org.springframework.messaging.Message; |
|
|
|
|
import org.springframework.messaging.MessageChannel; |
|
|
|
|
import org.springframework.messaging.SubscribableChannel; |
|
|
|
|
import org.springframework.util.Assert; |
|
|
|
|
import org.springframework.web.messaging.MessageType; |
|
|
|
|
import org.springframework.web.messaging.converter.CompositeMessageConverter; |
|
|
|
|
import org.springframework.web.messaging.converter.MessageConverter; |
|
|
|
|
@ -43,8 +44,6 @@ import org.springframework.web.messaging.service.AbstractPubSubMessageHandler;
@@ -43,8 +44,6 @@ import org.springframework.web.messaging.service.AbstractPubSubMessageHandler;
|
|
|
|
|
import org.springframework.web.messaging.stomp.StompCommand; |
|
|
|
|
import org.springframework.web.messaging.stomp.StompHeaders; |
|
|
|
|
|
|
|
|
|
import reactor.util.Assert; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* @author Rossen Stoyanchev |
|
|
|
|
|