Class DefaultHeaderChannelRegistry

All Implemented Interfaces:
Runnable, Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, Lifecycle, ExpressionCapable, HeaderChannelRegistry, NamedComponent, ManageableLifecycle

public class DefaultHeaderChannelRegistry extends IntegrationObjectSupport implements HeaderChannelRegistry, ManageableLifecycle, Runnable
Converts a channel to a name, retaining a reference to the channel keyed by the name. Allows a downstream BeanFactoryChannelResolver to find the channel by name in the event that the flow serialized the message at some point. Channels are expired after a configurable delay (60 seconds by default). The actual average expiry time will be 1.5x the delay.
Gary Russell, Artem Bilan, Trung Pham
  • Field Details

  • Constructor Details

    • DefaultHeaderChannelRegistry

      public DefaultHeaderChannelRegistry()
      Construct a registry with the default delay for channel expiry.
    • DefaultHeaderChannelRegistry

      public DefaultHeaderChannelRegistry(long reaperDelay)
      Construct a registry with the provided delay (milliseconds) for channel expiry.
      reaperDelay - the delay in milliseconds.
  • Method Details