Class WebSocketOutboundMessageHandler

All Implemented Interfaces:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

public class WebSocketOutboundMessageHandler extends AbstractMessageHandler
Since:
4.1
Author:
Artem Bilan
  • Constructor Details

  • Method Details

    • setMessageConverters

      public void setMessageConverters(List<MessageConverter> messageConverters)
      Set the message converters to use. These converters are used to convert the message to send for appropriate internal subProtocols type.
      Parameters:
      messageConverters - The message converters.
    • setMergeWithDefaultConverters

      public void setMergeWithDefaultConverters(boolean mergeWithDefaultConverters)
      Flag which determines if the default converters should be available after custom converters.
      Parameters:
      mergeWithDefaultConverters - true to merge, false to replace.
    • getComponentType

      public String getComponentType()
      Description copied from class: IntegrationObjectSupport
      Subclasses may implement this method to provide component type information.
      Specified by:
      getComponentType in interface NamedComponent
      Overrides:
      getComponentType in class MessageHandlerSupport
    • onInit

      protected void onInit()
      Description copied from class: IntegrationObjectSupport
      Subclasses may implement this for initialization logic.
      Overrides:
      onInit in class IntegrationObjectSupport
    • handleMessageInternal

      protected void handleMessageInternal(Message<?> message)
      Specified by:
      handleMessageInternal in class AbstractMessageHandler