Class ChannelRegistration

java.lang.Object
org.springframework.messaging.simp.config.ChannelRegistration
public class ChannelRegistration extends Object
A registration class for customizing the configuration for a MessageChannel.
Since:
4.0
Author:
Rossen Stoyanchev, Stephane Nicoll

  • Constructor Details

    • ChannelRegistration

      public ChannelRegistration()

  • Method Details

    • taskExecutor

      public TaskExecutorRegistration taskExecutor()
      Configure the thread pool backing this message channel.

    • taskExecutor

      public TaskExecutorRegistration taskExecutor(@Nullable ThreadPoolTaskExecutor taskExecutor)
      Configure the thread pool backing this message channel using a custom ThreadPoolTaskExecutor.
      Parameters:
      taskExecutor - the executor to use (or null for a default executor)

    • executor

      public ChannelRegistration executor(Executor executor)
      Configure the given Executor for this message channel, taking precedence over a task executor registration if any.
      Parameters:
      executor - the executor to use
      Since:
      6.2

    • interceptors

      public ChannelRegistration interceptors(ChannelInterceptor... interceptors)
      Configure the given interceptors for this message channel, adding them to the channel's current list of interceptors.
      Since:
      4.3.12

    • hasExecutor

      protected boolean hasExecutor()

    • hasInterceptors

      protected boolean hasInterceptors()

    • getExecutor

      protected Executor getExecutor(Supplier<Executor> fallback, Consumer<Executor> customizer)
      Return the Executor to use. If no executor has been configured, the fallback supplier is used to provide a fallback instance.

      If the Executor to use is suitable for further customizations, the customizer consumer is invoked.

      Parameters:
      fallback - a supplier of a fallback executor in case none is configured
      customizer - further customizations
      Returns:
      the executor to use
      Since:
      6.2

    • getInterceptors

      protected List<ChannelInterceptor> getInterceptors()