Package org.springframework.integration.channel
@NonNullApi
package org.springframework.integration.channel
Provides classes representing various channel types.
-
ClassDescriptionThe
AbstractSubscribableChannel
base implementation for those inheritors which logic may be based on theExecutor
.Base class forMessageChannel
implementations providing common properties such as the channel name.A convenience wrapper class for the list of ChannelInterceptors.Base class for all pollable channels.Base implementation ofMessageChannel
that invokes the subscribedhandler(s)
by delegating to aMessageDispatcher
.ASubscribableChannel
variant for implementations with broadcasting capabilities.A utility class for purgingMessages
from one or moreQueueChannels
.Channel utilities.Converts a channel to a name, retaining a reference to the channel keyed by the name.A channel that invokes a single subscriber for each sent Message.An implementation ofMessageChannel
that delegates to an instance ofUnicastingDispatcher
which in turn delegates all dispatching invocations to anExecutor
.TheInterceptableChannel
extension for the cases when theExecutorChannelInterceptor
s may have reason (e.g.SpecializedSubscribableChannel
for a single final subscriber set up during bean instantiation (unlike otherSubscribableChannel
s where theMessageHandler
is subscribed when the endpoint is started).TheAbstractMessageChannel
implementation for the Reactive StreamsPublisher
based on the Project ReactorFlux
.A channel implementation that essentially behaves like "/dev/null".AnAbstractExecutorChannel
implementation for partitioned message dispatching.A message channel that prioritizes messages based on aComparator
.A channel that sends Messages to each of its subscribers.Simple implementation of a message channel.Operations available on a channel that has queuing semantics.A zero-capacity version ofQueueChannel
that delegates to aSynchronousQueue
internally.