All Classes

Class	Description
AbstractBindableProxyFactory	Base class for bindable proxy factories.
AbstractBinder<T,C extends ConsumerProperties,P extends ProducerProperties>	Base class for Binder implementations.
AbstractBindingTargetFactory<T>	A BindingTargetFactory implementation that restricts the type of binding target to a specified class and its supertypes.
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
ApplicationMetricsProperties
Bindable	Marker interface for instances that can bind/unbind groups of inputs and outputs.
BindableProxyFactory	FactoryBean for instantiating the interfaces specified via EnableBinding.
Binder<T,C extends ConsumerProperties,P extends ProducerProperties>	A strategy interface used to bind an app interface to a logical name.
BinderAwareChannelResolver	Deprecated. As of 3.0.0 in favor if providing `spring.cloud.stream.sendto.destination` property.
BinderAwareChannelResolver.NewDestinationBindingCallback<T>	Configure a new destination before it is bound.
BinderAwareRouter	A BeanPostProcessor that sets a BinderAwareChannelResolver on any bean of type AbstractMappingMessageRouter within the context.
BinderConfiguration	Configuration for a binder instance, associating a BinderType with its configuration Properties.
BinderCustomizer
BinderException	Exception thrown to indicate a binder error (most likely a configuration error).
BinderFactory
BinderFactoryAutoConfiguration
BinderHeaders	Spring Integration message headers for Spring Cloud Stream.
BinderProperties	Contains the properties of a binder.
BindersHealthIndicatorAutoConfiguration
BindersHealthIndicatorAutoConfiguration.BindersHealthContributor	CompositeHealthContributor that provides binder health contributions.
BindersHealthIndicatorAutoConfiguration.BindersHealthIndicatorListener	A DefaultBinderFactory.Listener that provides HealthIndicator support.
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.
Binding<T>	Represents a binding between an input or output and an adapter endpoint that connects via a Binder.
BindingBeanDefinitionRegistryUtils	Utility class for registering bean definitions for binding targets.
BindingBeansRegistrar
BindingCleaner	Interface for implementations that perform cleanup for binders.
BindingCreatedEvent	ApplicationEvent fired whenever the the Binding is created.
BindingHandlerAdvise
BindingHandlerAdvise.MappingsProvider	Provides mappings including the default mappings.
BindingProperties	Contains the properties of a binding.
BindingsEndpoint	Actuator endpoint for binding control.
BindingsEndpointAutoConfiguration
BindingService	Handles binding of input/output targets by delegating to an underlying Binder.
BindingService.LateBinding<T>
BindingServiceConfiguration	Configuration class that provides necessary beans for MessageChannel binding.
BindingServiceProperties
BindingsLifecycleController	Lifecycle controller for the bindings.
BindingsLifecycleController.State	Binding states.
BindingTargetFactory	Defines methods to create/configure the binding targets defined by EnableBinding.
BoundTargetHolder	Holds information about the binding targets exposed by the interface proxy, as well as their status.
ChannelsEndpoint	An Endpoint that has the binding information on all the Bindable message channels.
ChannelsEndpoint.ChannelsMetaData	Meta data for channels.
ChannelsEndpointAutoConfiguration
CompositeMessageChannelConfigurer	MessageChannelConfigurer that composes all the message channel configurers.
CompositeMessageConverterFactory	A factory for creating an instance of CompositeMessageConverter for a given target MIME type.
ConsumerDestination	Represents a ConsumerDestination that provides the information about the destination that is physically provisioned through ProvisioningProvider.provisionConsumerDestination(String, String, ConsumerProperties).
ConsumerEndpointCustomizer<E extends org.springframework.integration.core.MessageProducer>	If a single bean of this type is in the application context, an inbound channel adapter created by the binder can be further customized after all the properties are set.
ConsumerProperties	Common consumer properties - spring.cloud.stream.bindings.[destinationName].consumer.
ContextStartAfterRefreshListener	Automatically starts the context after a refresh.
ConversionException	Exception thrown when an error is encountered during message conversion.
CustomMimeTypeConverter	A custom converter for MimeType that accepts a plain java class name as a shorthand for application/x-java-object;type=the.qualified.ClassName.
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.
DefaultPartitioningInterceptor
DefaultPollableMessageSource	The default implementation of a PollableMessageSource.
DestinationPublishingMetricsAutoConfiguration
DirectHandler
DirectWithAttributesChannel
DynamicDestinationsBindable	A Bindable that stores the dynamic destination names and handles their unbinding.
EmbeddedHeaderUtils	Encodes requested headers into payload with format 0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] ... ].
EnableBinding	Deprecated. as of 3.1 in favor of functional programming model
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.
FunctionConfiguration
FunctionConstants	Interfaces which defines constants used for naming conventions used in bindings of multiple functions or functions with multiple inputs and outputs.
GenericsUtils	Internal utilities for handling generics.
HeaderMode
Input	Deprecated. as of 3.1 in favor of functional programming model
InputBindingLifecycle	Coordinates binding/unbinding of input binding targets in accordance to the lifecycle of the host context.
InternalPropertyNames	Contains the names of properties for the internal use of Spring Cloud Stream.
JavaClassMimeTypeUtils	Handles representing any java class as a MimeType.
LastSubscriberMessageHandler	A marker interface designating a subscriber that must be the last.
ListenerContainerCustomizer<T>	If a single bean of this type is in the application context, listener containers created by the binder can be further customized after all the properties are set.
MessageChannelAndSourceConfigurer	Configurer for PollableMessageSource.
MessageChannelConfigurer	Interface to be implemented by the classes that configure the Bindable message channels.
MessageChannelStreamListenerResultAdapter	A StreamListenerResultAdapter used for bridging an Output MessageChannel to a bound MessageChannel.
MessageConverterConfigurer	A MessageChannelConfigurer that sets data types and message converters based on BindingProperties.contentType.
MessageConverterUtils	Message conversion utility methods.
MessageSourceBindingTargetFactory	An implementation of BindingTargetFactory for creating DefaultPollableMessageSources.
MessageSourceCustomizer<T>	If a single bean of this type is in the application context, pollable message sources created by the binder can be further customized after all the properties are set.
MessageValues	A mutable type for allowing Binder implementations to transform and enrich message content more efficiently.
MetersPublisherBinding
ObjectStringMessageConverter	A MessageConverter to convert a non-String objects to a String, when expected content type is "text/plain".
Output	Deprecated. as of 3.1 in favor of functional programming model
OutputBindingLifecycle	Coordinates binding/unbinding of output binding targets in accordance to the lifecycle of the host context.
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.
PollerConfigEnvironmentPostProcessor
Processor	Bindable interface with one input and one output channel.
ProducerDestination	Represents a ProducerDestination that provides the information about the destination that is physically provisioned through ProvisioningProvider.provisionProducerDestination(String, ProducerProperties).
ProducerMessageHandlerCustomizer<H extends org.springframework.messaging.MessageHandler>	If a single bean of this type is in the application context, a producing message handler created by the binder can be further customized after all the properties are set.
ProducerProperties	Common producer properties.
ProducerProperties.PollerProperties
ProvisioningException	Generic unchecked exception to wrap middleware or technology specific exceptions.
ProvisioningProvider<C extends ConsumerProperties,P extends ProducerProperties>	Provisioning SPI that allows the users to provision destinations such as queues and topics.
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.
Sink	Bindable interface with one input channel.
Source	Bindable interface with one output channel.
SpelExpressionConverterConfiguration	Adds a Converter from String to SpEL Expression in the context.
SpelExpressionConverterConfiguration.SpelConverter	A simple converter from String to Expression.
SpringIntegrationProperties	Contains properties for Spring Integration settings.
StreamAnnotationCommonMethodUtils	Common methods that can be used across various Stream annotations.
StreamAnnotationErrorMessages
StreamBridge	A class which allows user to send data to an output binding.
StreamFunctionProperties
StreamListener	Deprecated. as of 3.1 in favor of functional programming model
StreamListenerAnnotationBeanPostProcessor	BeanPostProcessor that handles StreamListener annotations found on bean methods.
StreamListenerErrorMessages
StreamListenerMessageHandler
StreamListenerMethodUtils	This class contains utility methods for handling StreamListener annotated bean methods.
StreamListenerParameterAdapter<A,B>	Strategy for adapting a method argument type annotated with Input or Output from a binding type (e.g.
StreamListenerResultAdapter<R,B>	A strategy for adapting the result of a StreamListener annotated method to a binding target annotated with Output.
StreamListenerSetupMethodOrchestrator	Orchestrator used for invoking the StreamListener setup method.
StreamMessageConverter	Deprecated. as of 3.0 and is not used by the framework anymore.
StreamRetryTemplate	Marker to tag an instance of RetryTemplate to be used by the binder.
SubscribableChannelBindingTargetFactory	An implementation of BindingTargetFactory for creating SubscribableChannels.