public abstract class WebSocketMessageBrokerConfigurationSupport
extends java.lang.Object
@EnableWebSocketMessageBroker and
WebSocketMessageBrokerConfigurer.| Modifier and Type | Field and Description |
|---|---|
private static boolean |
jackson2Present |
private MessageBrokerConfigurer |
messageBrokerConfigurer |
private static AbstractBrokerMessageHandler |
noopBroker |
| Constructor and Description |
|---|
WebSocketMessageBrokerConfigurationSupport() |
private static final boolean jackson2Present
private MessageBrokerConfigurer messageBrokerConfigurer
private static final AbstractBrokerMessageHandler noopBroker
public WebSocketMessageBrokerConfigurationSupport()
@Bean public HandlerMapping brokerWebSocketHandlerMapping()
@Bean public WebSocketHandler subProtocolWebSocketHandler()
@Bean public MutableUserQueueSuffixResolver userQueueSuffixResolver()
@Bean public ThreadPoolTaskScheduler brokerDefaultSockJsTaskScheduler()
SockJsServiceRegistration#setTaskScheduler(), i.e.
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/stomp").withSockJS().setTaskScheduler(myScheduler());
}
// ...
}
protected void registerStompEndpoints(StompEndpointRegistry registry)
@Bean public SubscribableChannel webSocketRequestChannel()
@Bean public SubscribableChannel webSocketResponseChannel()
@Bean public ThreadPoolTaskExecutor webSocketChannelExecutor()
@Bean public SimpAnnotationMethodMessageHandler annotationMethodMessageHandler()
@Bean public AbstractBrokerMessageHandler simpleBrokerMessageHandler()
@Bean public AbstractBrokerMessageHandler stompBrokerRelayMessageHandler()
protected final MessageBrokerConfigurer getMessageBrokerConfigurer()
protected void configureMessageBroker(MessageBrokerConfigurer configurer)
@Bean public UserDestinationMessageHandler userDestinationMessageHandler()
@Bean public SimpMessageSendingOperations brokerMessagingTemplate()
@Bean public SubscribableChannel brokerChannel()
@Bean public CompositeMessageConverter simpMessageConverter()