public abstract class AbstractMessageBrokerConfiguration extends Object implements ApplicationContextAware
clientInboundChannel() and clientOutboundChannel() deliver messages
to and from remote clients to several message handlers such as
simpAnnotationMethodMessageHandler()simpleBrokerMessageHandler()stompBrokerRelayMessageHandler()userDestinationMessageHandler()brokerChannel() delivers messages from within the application to the
the respective message handlers. brokerMessagingTemplate() can be injected
into any application component to send messages.
Sub-classes are responsible for the part of the configuration that feed messages to and from the client inbound/outbound channels (e.g. STOMP over WebSocket).
| Modifier | Constructor and Description |
|---|---|
protected |
AbstractMessageBrokerConfiguration()
Protected constructor.
|
protected AbstractMessageBrokerConfiguration()
@Bean public AbstractSubscribableChannel clientInboundChannel()
@Bean public ThreadPoolTaskExecutor clientInboundChannelExecutor()
protected final ChannelRegistration getClientInboundChannelRegistration()
protected void configureClientInboundChannel(ChannelRegistration registration)
@Bean public AbstractSubscribableChannel clientOutboundChannel()
@Bean public ThreadPoolTaskExecutor clientOutboundChannelExecutor()
protected final ChannelRegistration getClientOutboundChannelRegistration()
protected void configureClientOutboundChannel(ChannelRegistration registration)
@Bean public AbstractSubscribableChannel brokerChannel()
@Bean public ThreadPoolTaskExecutor brokerChannelExecutor()
protected final MessageBrokerRegistry getBrokerRegistry()
MessageBrokerRegistry that ensures its one-time creation
and initialization through configureMessageBroker(MessageBrokerRegistry).protected void configureMessageBroker(MessageBrokerRegistry registry)
MessageBrokerRegistry instance.@Bean public SimpAnnotationMethodMessageHandler simpAnnotationMethodMessageHandler()
protected void addArgumentResolvers(List<HandlerMethodArgumentResolver> argumentResolvers)
protected void addReturnValueHandlers(List<HandlerMethodReturnValueHandler> returnValueHandlers)
@Bean public AbstractBrokerMessageHandler simpleBrokerMessageHandler()
@Bean public AbstractBrokerMessageHandler stompBrokerRelayMessageHandler()
@Bean public UserDestinationMessageHandler userDestinationMessageHandler()
@Bean public SimpMessagingTemplate brokerMessagingTemplate()
@Bean public CompositeMessageConverter brokerMessageConverter()
protected boolean configureMessageConverters(List<MessageConverter> messageConverters)
messageConverters - the list to add converters to, initially emptytrue if default message converters should be added to list,
false if no more converters should be added.@Bean public UserDestinationResolver userDestinationResolver()
@Bean public UserSessionRegistry userSessionRegistry()
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
ApplicationContextAwareInvoked after population of normal bean properties but before an init callback such
as InitializingBean.afterPropertiesSet()
or a custom init-method. Invoked after ResourceLoaderAware.setResourceLoader(org.springframework.core.io.ResourceLoader),
ApplicationEventPublisherAware.setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher) and
MessageSourceAware, if applicable.
setApplicationContext in interface ApplicationContextAwareapplicationContext - the ApplicationContext object to be used by this objectApplicationContextException - in case of context initialization errorsBeansException - if thrown by application context methodsBeanInitializationExceptionpublic ApplicationContext getApplicationContext()
protected Validator simpValidator()
Validators instance for validating
@Payload method arguments.
In order, this method tries to get a Validator instance:
OptionalValidatorFactoryBean