Package org.springframework.integration.channel
Provides classes representing various channel types.
-
Interface Summary Interface Description BroadcastCapableChannel ASubscribableChannelvariant for implementations with broadcasting capabilities.ExecutorChannelInterceptorAware TheInterceptableChannelextension for the cases when theExecutorChannelInterceptors may have reason (e.g.QueueChannelOperations Operations available on a channel that has queuing semantics.ReactiveStreamsSubscribableChannel -
Class Summary Class Description AbstractExecutorChannel TheAbstractSubscribableChannelbase implementation for those inheritors which logic may be based on theExecutor.AbstractMessageChannel Base class forMessageChannelimplementations providing common properties such as the channel name.AbstractMessageChannel.ChannelInterceptorList A convenience wrapper class for the list of ChannelInterceptors.AbstractPollableChannel Base class for all pollable channels.AbstractSubscribableChannel Base implementation ofMessageChannelthat invokes the subscribedhandler(s)by delegating to aMessageDispatcher.ChannelPurger A utility class for purgingMessagesfrom one or moreQueueChannels.ChannelUtils Channel utilities.DefaultHeaderChannelRegistry Converts a channel to a name, retaining a reference to the channel keyed by the name.DirectChannel A channel that invokes a single subscriber for each sent Message.ExecutorChannel An implementation ofMessageChannelthat delegates to an instance ofUnicastingDispatcherwhich in turn delegates all dispatching invocations to anExecutor.FixedSubscriberChannel SpecializedSubscribableChannelfor a single final subscriber set up during bean instantiation (unlike otherSubscribableChannels where theMessageHandleris subscribed when the endpoint is started).FluxMessageChannel TheAbstractMessageChannelimplementation for the Reactive StreamsPublisherbased on the Project ReactorFlux.MessageChannelReactiveUtils Deprecated. since 5.3 in favor ofIntegrationReactiveUtils.MessagePublishingErrorHandler NullChannel A channel implementation that essentially behaves like "/dev/null".PriorityChannel A message channel that prioritizes messages based on aComparator.PublishSubscribeChannel A channel that sends Messages to each of its subscribers.QueueChannel Simple implementation of a message channel.RendezvousChannel A zero-capacity version ofQueueChannelthat delegates to aSynchronousQueueinternally.