Package org.springframework.cloud.stream.binder

Interface Summary

Interface	Description
Binder<T,C extends ConsumerProperties,P extends ProducerProperties>	A strategy interface used to bind an app interface to a logical name.
BinderCustomizer
BinderFactory
BinderSpecificPropertiesProvider
BinderTypeRegistry	A registry of BinderTypes, indexed by name.
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.
DefaultBinderFactory.Listener	A listener that can be registered with the DefaultBinderFactory that allows the registration of additional configuration.
ExtendedBindingProperties<C,P>	Properties that extend the common binding properties for a particular binder implementation.
ExtendedPropertiesBinder<T,C,P>	Extension of Binder that takes ExtendedConsumerProperties and ExtendedProducerProperties as arguments.
LastSubscriberMessageHandler	A marker interface designating a subscriber that must be the last.
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.

Class Summary

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
BinderConfiguration	Configuration for a binder instance, associating a BinderType with its configuration Properties.
BinderHeaders	Spring Integration message headers for Spring Cloud Stream.
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.
BindingCreatedEvent	ApplicationEvent fired whenever the the Binding is created.
ConsumerProperties	Common consumer properties - spring.cloud.stream.bindings.[destinationName].consumer.
DefaultBinderFactory	Default BinderFactory implementation.
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] ... ].
ExtendedConsumerProperties<T>	Extension of ConsumerProperties to be used with an ExtendedPropertiesBinder.
ExtendedProducerProperties<T>
JavaClassMimeTypeUtils	Handles representing any java class as a MimeType.
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.
ProducerProperties	Common producer properties.
ProducerProperties.PollerProperties

Enum Summary

Enum	Description
HeaderMode

Exception Summary

Exception	Description
BinderException	Exception thrown to indicate a binder error (most likely a configuration error).
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.