Package org.springframework.cloud.stream.binder

package org.springframework.cloud.stream.binder

Class	Description
AbstractBinder<T, C extends ConsumerProperties, P extends ProducerProperties>	Base class for Binder implementations.
AbstractExtendedBindingProperties<C, P, T extends BinderSpecificPropertiesProvider>	Base implementation of ExtendedBindingProperties.
AbstractMessageChannelBinder<C extends ConsumerProperties, P extends ProducerProperties, PP extends ProvisioningProvider<C,P>>	AbstractBinder that serves as base class for MessageChannel binders.
AbstractMessageChannelBinder.ErrorInfrastructure
AbstractMessageChannelBinder.PolledConsumerResources
Binder<T, C extends ConsumerProperties, P extends ProducerProperties>	A strategy interface used to bind an app interface to a logical name.
BinderChildContextInitializer
BinderConfiguration	Configuration for a binder instance, associating a BinderType with its configuration Properties.
BinderCustomizer	The binder customization strategy.
BinderException	Exception thrown to indicate a binder error (most likely a configuration error).
BinderFactory
BinderHeaders	Spring Integration message headers for Spring Cloud Stream.
BinderSpecificPropertiesProvider
BinderType	References one or more Configuration-annotated classes which provide a context definition which contains exactly one Binder, typically for a given type of system (e.g.
BinderTypeRegistry	A registry of BinderTypes, indexed by name.
BinderWrapper	Holds information about the binder and channel.
Binding<T>	Represents a binding between an input or output and an adapter endpoint that connects via a Binder.
BindingCleaner	Interface for implementations that perform cleanup for binders.
BindingCreatedEvent	ApplicationEvent fired whenever the the Binding is created.
ConsumerProperties	Common consumer properties - spring.cloud.stream.bindings.
DefaultBinderFactory	Default BinderFactory implementation.
DefaultBinderFactory.Listener	A listener that can be registered with the DefaultBinderFactory that allows the registration of additional configuration.
DefaultBinderTypeRegistry	Default implementation of a BinderTypeRegistry.
DefaultBinding<T>	Default implementation for a Binding.
DefaultPollableMessageSource	The default implementation of a PollableMessageSource.
DirectHandler
EmbeddedHeaderUtils	Encodes requested headers into payload with format 0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] ... ].
ExpressionSerializer	since 5.0.2 author Oleg Zhurakousky
ExtendedBindingProperties<C,P>	Properties that extend the common binding properties for a particular binder implementation.
ExtendedConsumerProperties<T>	Extension of ConsumerProperties to be used with an ExtendedPropertiesBinder.
ExtendedProducerProperties<T>
ExtendedPropertiesBinder<T,C,P>	Extension of Binder that takes ExtendedConsumerProperties and ExtendedProducerProperties as arguments.
HeaderMode
JavaClassMimeTypeUtils	Handles representing any java class as a MimeType.
LastSubscriberMessageHandler	A marker interface designating a subscriber that must be the last.
MessageValues	A mutable type for allowing Binder implementations to transform and enrich message content more efficiently.
PartitionHandler	Utility class to determine if a binding is configured for partitioning (based on the binder properties provided in the constructor) and what partition a message should be delivered to.
PartitionKeyExtractorStrategy	Strategy for extracting a partition key from a Message.
PartitionSelectorStrategy	Strategy for determining the partition to which a message should be sent.
PollableConsumerBinder<H, C extends ConsumerProperties>	A binder that supports pollable message sources.
PollableMessageSource	A PollableSource that calls a MessageHandler with a Message.
PollableSource<H>	A mechanism to poll a consumer.
ProducerProperties	Common producer properties.
ProducerProperties.ExpressionSerializer	Deprecated. since 5.0.2 in favor of top level class in the same package
ProducerProperties.PollerProperties
RequeueCurrentMessageException	When using a PollableMessageSource throw this exception to cause the current message to be requeued in the broker so that it will be redelivered on the next poll.