A B C D E F G H I J K L M N O P R S T U V X

A

AbstractBinder<T,C extends ConsumerProperties,P extends ProducerProperties> - Class in org.springframework.cloud.stream.binder

AbstractBinder() - Constructor for class org.springframework.cloud.stream.binder.AbstractBinder

AbstractBinder.JavaClassMimeTypeConversion - Class in org.springframework.cloud.stream.binder

Handles representing any java class as a MimeType.

AbstractFromMessageConverter - Class in org.springframework.cloud.stream.converter

Base class for converters applied via Spring Integration 4.x data type channels.

AbstractFromMessageConverter(MimeType) - Constructor for class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Creates a converter that ignores content-type message headers

AbstractFromMessageConverter(Collection<MimeType>) - Constructor for class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

AbstractFromMessageConverter(Collection<MimeType>, MimeType) - Constructor for class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Creates a converter that handles one or more content-type message headers

AbstractFromMessageConverter(Collection<MimeType>, Collection<MimeType>) - Constructor for class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Creates a converter that handles one or more content-type message headers and one or more target MIME types

AbstractFromMessageConverter(MimeType, MimeType) - Constructor for class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Creates a converter that requires a specific content-type message header

AbstractFromMessageConverter(MimeType, Collection<MimeType>) - Constructor for class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Creates a converter that requires a specific content-type message header and supports multiple target MIME types.

addOutputBinding(String, Binding) - Method in class org.springframework.cloud.stream.binding.DynamicDestinationsBindable

afterPropertiesSet() - Method in class org.springframework.cloud.stream.binder.AbstractBinder

afterPropertiesSet() - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

afterPropertiesSet() - Method in class org.springframework.cloud.stream.binding.MessageConverterConfigurer

afterPropertiesSet() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

afterSingletonsInstantiated() - Method in class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor

afterUnbind() - Method in class org.springframework.cloud.stream.binder.DefaultBinding

AggregateApplicationBuilder - Class in org.springframework.cloud.stream.aggregate

Application builder for AggregateApplication.

AggregateApplicationBuilder() - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

AggregateApplicationBuilder(Object, String...) - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

AggregateApplicationBuilder(Object[], String[]) - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

AggregateApplicationBuilder(ConfigurableApplicationContext) - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

AggregateApplicationBuilder.AppConfigurer<T extends AggregateApplicationBuilder.AppConfigurer<T>> - Class in org.springframework.cloud.stream.aggregate

AggregateApplicationBuilder.ProcessorConfigurer - Class in org.springframework.cloud.stream.aggregate

AggregateApplicationBuilder.SinkConfigurer - Class in org.springframework.cloud.stream.aggregate

AggregateApplicationBuilder.SourceConfigurer - Class in org.springframework.cloud.stream.aggregate

AggregatorParentConfiguration - Class in org.springframework.cloud.stream.aggregate

Basic configuration for an aggregator application parent.

AggregatorParentConfiguration() - Constructor for class org.springframework.cloud.stream.aggregate.AggregatorParentConfiguration

AppConfigurer() - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer

applyPrefix(String, String) - Static method in class org.springframework.cloud.stream.binder.AbstractBinder

For binder implementations that support a prefix, apply the prefix to the name.

args(String...) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer

as(String...) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer

asMapProperties() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

Return configuration properties as Map.

B

Bindable - Interface in org.springframework.cloud.stream.binding

Marker interface for instances that can bind/unbind groups of inputs and outputs.

BindableAdapter - Class in org.springframework.cloud.stream.binding

Default adapter implementation for .

BindableAdapter() - Constructor for class org.springframework.cloud.stream.binding.BindableAdapter

BindableChannelFactory - Interface in org.springframework.cloud.stream.binding

Defines methods to create/configure the MessageChannels defined in EnableBinding.

BindableProxyFactory - Class in org.springframework.cloud.stream.binding

FactoryBean for instantiating the interfaces specified via EnableBinding

BindableProxyFactory(Class<?>) - Constructor for class org.springframework.cloud.stream.binding.BindableProxyFactory

bindConsumer(String, String, T, C) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

bindConsumer(String, String, T, C) - Method in interface org.springframework.cloud.stream.binder.Binder

Bind the target component as a message consumer to the logical entity identified by the name.

bindConsumer(MessageChannel, String) - Method in class org.springframework.cloud.stream.binding.ChannelBindingService

Binder<T,C extends ConsumerProperties,P extends ProducerProperties> - Interface in org.springframework.cloud.stream.binder

A strategy interface used to bind an app interface to a logical name.

BINDER_ORIGINAL_CONTENT_TYPE - Static variable in class org.springframework.cloud.stream.binder.BinderHeaders

BinderAwareChannelResolver - Class in org.springframework.cloud.stream.binding

A DestinationResolver implementation that resolves the channel from the bean factory and, if not present, creates a new channel and adds it to the factory after binding it to the binder.

BinderAwareChannelResolver(ChannelBindingService, BindableChannelFactory, DynamicDestinationsBindable) - Constructor for class org.springframework.cloud.stream.binding.BinderAwareChannelResolver

binderAwareChannelResolver(ChannelBindingService, BindableChannelFactory, DynamicDestinationsBindable) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

BinderAwareRouterBeanPostProcessor - Class in org.springframework.cloud.stream.binding

A BeanPostProcessor that sets a BinderAwareChannelResolver on any bean of type AbstractMappingMessageRouter within the context.

BinderAwareRouterBeanPostProcessor(DestinationResolver<MessageChannel>) - Constructor for class org.springframework.cloud.stream.binding.BinderAwareRouterBeanPostProcessor

binderAwareRouterBeanPostProcessor(ConfigurableListableBeanFactory) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration.PostProcessorConfiguration

BinderConfiguration - Class in org.springframework.cloud.stream.binder

Configuration for a binder instance, associating a BinderType with its configuration Properties.

BinderConfiguration(BinderType, Properties, boolean, boolean) - Constructor for class org.springframework.cloud.stream.binder.BinderConfiguration

BinderException - Exception in org.springframework.cloud.stream.binder

Exception thrown to indicate a binder error (most likely a configuration error).

BinderException(String) - Constructor for exception org.springframework.cloud.stream.binder.BinderException

BinderException(String, Throwable) - Constructor for exception org.springframework.cloud.stream.binder.BinderException

BinderFactory<T> - Interface in org.springframework.cloud.stream.binder

binderFactory(BinderTypeRegistry, ChannelBindingServiceProperties) - Method in class org.springframework.cloud.stream.config.BinderFactoryConfiguration

BinderFactoryConfiguration - Class in org.springframework.cloud.stream.config

BinderFactoryConfiguration() - Constructor for class org.springframework.cloud.stream.config.BinderFactoryConfiguration

BinderHeaders - Class in org.springframework.cloud.stream.binder

Spring Integration message headers for Spring Cloud Stream.

BinderProperties - Class in org.springframework.cloud.stream.config

Contains the properties of a binder.

BinderProperties() - Constructor for class org.springframework.cloud.stream.config.BinderProperties

bindersHealthIndicator() - Method in class org.springframework.cloud.stream.config.ChannelBindingAutoConfiguration

BinderType - Class in org.springframework.cloud.stream.binder

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.

BinderType(String, Class<?>[]) - Constructor for class org.springframework.cloud.stream.binder.BinderType

BinderTypeRegistry - Interface in org.springframework.cloud.stream.binder

A registry of BinderTypes, indexed by name.

binderTypeRegistry(ConfigurableApplicationContext) - Method in class org.springframework.cloud.stream.config.BinderFactoryConfiguration

Binding<T> - Interface in org.springframework.cloud.stream.binder

Represents a binding between an input or output and an adapter endpoint that connects via a Binder.

BindingBeanDefinitionRegistryUtils - Class in org.springframework.cloud.stream.binding

Utility class for registering bean definitions for message channels.

BindingBeanDefinitionRegistryUtils() - Constructor for class org.springframework.cloud.stream.binding.BindingBeanDefinitionRegistryUtils

BindingBeansRegistrar - Class in org.springframework.cloud.stream.config

BindingBeansRegistrar() - Constructor for class org.springframework.cloud.stream.config.BindingBeansRegistrar

BindingCleaner - Interface in org.springframework.cloud.stream.binder

Interface for implementations that perform cleanup for binders.

BindingProperties - Class in org.springframework.cloud.stream.config

Contains the properties of a binding.

BindingProperties() - Constructor for class org.springframework.cloud.stream.config.BindingProperties

Bindings - Annotation Type in org.springframework.cloud.stream.annotation

Indicates an instance of an interface containing methods returning bound inputs and outputs.

bindingService(ChannelBindingServiceProperties, BinderFactory<MessageChannel>) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

bindInputs(ChannelBindingService) - Method in interface org.springframework.cloud.stream.binding.Bindable

Binds all the inputs associated with this instance.

bindInputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.BindableAdapter

bindInputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

bindOutputs(ChannelBindingService) - Method in interface org.springframework.cloud.stream.binding.Bindable

Binds all the outputs associated with this instance.

bindOutputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.BindableAdapter

bindOutputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

bindOutputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.SingleChannelBindable

bindProducer(String, T, P) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

bindProducer(String, T, P) - Method in interface org.springframework.cloud.stream.binder.Binder

Bind the target component as a message producer to the logical entity identified by the name.

bindProducer(MessageChannel, String) - Method in class org.springframework.cloud.stream.binding.ChannelBindingService

bindToAnnotationBeanPostProcessor(BinderAwareChannelResolver, MessageHandlerMethodFactory) - Static method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

buildPartitionRoutingExpression(String) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

buildRetryTemplateIfRetryEnabled(ConsumerProperties) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

Create and configure a retry template if the consumer 'maxAttempts' property is set.

ByteArrayToStringMessageConverter - Class in org.springframework.cloud.stream.converter

A MessageConverter to convert from byte[] to String applying the Charset provided in the content-type header if any.

ByteArrayToStringMessageConverter() - Constructor for class org.springframework.cloud.stream.converter.ByteArrayToStringMessageConverter

C

canConvertFrom(Message<?>, Class<?>) - Method in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

canConvertTo(Object, MessageHeaders) - Method in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Not supported by default

ChannelBindingAutoConfiguration - Class in org.springframework.cloud.stream.config

Configuration class with some useful beans for MessageChannel binding and general Spring Integration infrastructure.

ChannelBindingAutoConfiguration() - Constructor for class org.springframework.cloud.stream.config.ChannelBindingAutoConfiguration

ChannelBindingService - Class in org.springframework.cloud.stream.binding

Handles the operations related to channel binding including binding of input/output channels by delegating to an underlying Binder, setting up data type conversion for binding channel.

ChannelBindingService(ChannelBindingServiceProperties, BinderFactory<MessageChannel>) - Constructor for class org.springframework.cloud.stream.binding.ChannelBindingService

ChannelBindingServiceConfiguration - Class in org.springframework.cloud.stream.config

Configuration class that provides necessary beans for MessageChannel binding.

ChannelBindingServiceConfiguration() - Constructor for class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

ChannelBindingServiceConfiguration.PostProcessorConfiguration - Class in org.springframework.cloud.stream.config

ChannelBindingServiceProperties - Class in org.springframework.cloud.stream.config

ChannelBindingServiceProperties() - Constructor for class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

channelFactory(CompositeMessageChannelConfigurer) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

channelsEndpoint(ChannelBindingServiceProperties) - Method in class org.springframework.cloud.stream.config.ChannelBindingAutoConfiguration

ChannelsEndpoint - Class in org.springframework.cloud.stream.endpoint

An Endpoint that has the binding information on all the Bindable message channels.

ChannelsEndpoint(List<Bindable>, ChannelBindingServiceProperties) - Constructor for class org.springframework.cloud.stream.endpoint.ChannelsEndpoint

ChannelsEndpoint.ChannelsMetaData - Class in org.springframework.cloud.stream.endpoint

ChannelsMetaData() - Constructor for class org.springframework.cloud.stream.endpoint.ChannelsEndpoint.ChannelsMetaData

clean(String, boolean) - Method in interface org.springframework.cloud.stream.binder.BindingCleaner

Clean up all resources for the supplied stream/job.

clear() - Method in class org.springframework.cloud.stream.binder.MessageValues

codec() - Method in class org.springframework.cloud.stream.config.codec.kryo.KryoCodecAutoConfiguration

CompositeMessageChannelConfigurer - Class in org.springframework.cloud.stream.binding

MessageChannelConfigurer that composes all the message channel configurers.

CompositeMessageChannelConfigurer(List<MessageChannelConfigurer>) - Constructor for class org.springframework.cloud.stream.binding.CompositeMessageChannelConfigurer

compositeMessageChannelConfigurer(MessageConverterConfigurer) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

compositeMessageConverterFactory() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

CompositeMessageConverterFactory - Class in org.springframework.cloud.stream.converter

A factory for creating an instance of CompositeMessageConverter for a given target MIME type

CompositeMessageConverterFactory() - Constructor for class org.springframework.cloud.stream.converter.CompositeMessageConverterFactory

CompositeMessageConverterFactory(List<? extends AbstractFromMessageConverter>, ObjectMapper) - Constructor for class org.springframework.cloud.stream.converter.CompositeMessageConverterFactory

configureMessageChannel(MessageChannel, String) - Method in class org.springframework.cloud.stream.binding.CompositeMessageChannelConfigurer

configureMessageChannel(MessageChannel, String) - Method in interface org.springframework.cloud.stream.binding.MessageChannelConfigurer

Configure the given message channel.

configureMessageChannel(MessageChannel, String) - Method in class org.springframework.cloud.stream.binding.MessageConverterConfigurer

Setup data-type and message converters for the given message channel.

constructDLQName(String) - Static method in class org.springframework.cloud.stream.binder.AbstractBinder

For binder implementations that support dead lettering, construct the name of the dead letter entity for the underlying pipe name.

ConsumerProperties - Class in org.springframework.cloud.stream.binder

Common consumer properties.

ConsumerProperties() - Constructor for class org.springframework.cloud.stream.binder.ConsumerProperties

containsKey(Object) - Method in class org.springframework.cloud.stream.binder.MessageValues

containsValue(Object) - Method in class org.springframework.cloud.stream.binder.MessageValues

ContextStartAfterRefreshListener - Class in org.springframework.cloud.stream.binding

Automatically starts the context after a refresh.

ContextStartAfterRefreshListener() - Constructor for class org.springframework.cloud.stream.binding.ContextStartAfterRefreshListener

contextStartAfterRefreshListener() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

ConversionException - Exception in org.springframework.cloud.stream.converter

Exception thrown when an error is encountered during message conversion.

ConversionException(String) - Constructor for exception org.springframework.cloud.stream.converter.ConversionException

ConversionException(String, Throwable) - Constructor for exception org.springframework.cloud.stream.converter.ConversionException

convert(String) - Method in class org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration.SpelConverter

convert(String) - Method in class org.springframework.cloud.stream.converter.CustomMimeTypeConverter

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.ByteArrayToStringMessageConverter

Don't need to manipulate message headers.

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.JavaToSerializedMessageConverter

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.JsonToPojoMessageConverter

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.JsonToTupleMessageConverter

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.PojoToJsonMessageConverter

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.PojoToStringMessageConverter

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.SerializedToJavaMessageConverter

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.StringToByteArrayMessageConverter

Don't need to manipulate message headers.

convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.TupleToJsonMessageConverter

convertToInternal(Object, MessageHeaders, Object) - Method in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Not supported by default

copyHeadersIfAbsent(Map<String, Object>) - Method in class org.springframework.cloud.stream.binder.MessageValues

createSubscribableChannel(String) - Method in interface org.springframework.cloud.stream.binding.BindableChannelFactory

Create a SubscribableChannel that will be bound via the message channel Binder.

createSubscribableChannel(String) - Method in class org.springframework.cloud.stream.binding.DefaultBindableChannelFactory

CustomMimeTypeConverter - Class in org.springframework.cloud.stream.converter

A custom converter for MediaType that accepts a plain java class name as a shorthand for application/x-java-object;type=the.qualified.ClassName.

CustomMimeTypeConverter() - Constructor for class org.springframework.cloud.stream.converter.CustomMimeTypeConverter

D

decodeExceptionMessage(Message<?>) - Static method in class org.springframework.cloud.stream.binder.EmbeddedHeadersMessageConverter

DefaultBindableChannelFactory - Class in org.springframework.cloud.stream.binding

Class that BindableProxyFactory uses to create and configure message channels.

DefaultBindableChannelFactory(MessageChannelConfigurer) - Constructor for class org.springframework.cloud.stream.binding.DefaultBindableChannelFactory

DefaultBinderFactory<T> - Class in org.springframework.cloud.stream.binder

Default BinderFactory implementation.

DefaultBinderFactory(Map<String, BinderConfiguration>) - Constructor for class org.springframework.cloud.stream.binder.DefaultBinderFactory

DefaultBinderTypeRegistry - Class in org.springframework.cloud.stream.binder

Defult implementation of a BinderTypeRegistry.

DefaultBinderTypeRegistry(Map<String, BinderType>) - Constructor for class org.springframework.cloud.stream.binder.DefaultBinderTypeRegistry

DefaultBinding<T> - Class in org.springframework.cloud.stream.binder

Default implementation for a Binding.

DefaultBinding(String, String, T, AbstractEndpoint) - Constructor for class org.springframework.cloud.stream.binder.DefaultBinding

defaultPoller() - Method in class org.springframework.cloud.stream.config.ChannelBindingAutoConfiguration

DefaultPollerProperties - Class in org.springframework.cloud.stream.config

DefaultPollerProperties() - Constructor for class org.springframework.cloud.stream.config.DefaultPollerProperties

deserializePayloadIfNecessary(Message<?>) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

deserializePayloadIfNecessary(MessageValues) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

destroy() - Method in class org.springframework.cloud.stream.binder.DefaultBinderFactory

determinePartition(Message<?>) - Method in class org.springframework.cloud.stream.binder.PartitionHandler

Determine the partition to which to send this message.

DirectHandler - Class in org.springframework.cloud.stream.binder

DirectHandler(MessageChannel) - Constructor for class org.springframework.cloud.stream.binder.DirectHandler

doBindConsumer(String, String, T, C) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

doBindProducer(String, T, P) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

doManualAck(LinkedList<MessageHeaders>) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

Perform manual acknowledgement based on the metadata stored in the binder.

DynamicDestinationsBindable - Class in org.springframework.cloud.stream.binding

A BindableAdapter that stores the dynamic destination names and handles their unbinding.

DynamicDestinationsBindable() - Constructor for class org.springframework.cloud.stream.binding.DynamicDestinationsBindable

dynamicDestinationsBindable() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

E

embeddedHeadersMessageConverter - Variable in class org.springframework.cloud.stream.binder.AbstractBinder

EmbeddedHeadersMessageConverter - Class in org.springframework.cloud.stream.binder

Encodes requested headers into payload with format {@code 0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] ...

EmbeddedHeadersMessageConverter() - Constructor for class org.springframework.cloud.stream.binder.EmbeddedHeadersMessageConverter

embedHeaders(MessageValues, String...) - Method in class org.springframework.cloud.stream.binder.EmbeddedHeadersMessageConverter

Return a new message where some of the original headers of original have been embedded into the new message payload.

EnableBinding - Annotation Type in org.springframework.cloud.stream.annotation

Enables the binding of components annotated with Input and Output to a broker, according to the list of interfaces passed as value to the annotation.

EnableRxJavaProcessor - Annotation Type in org.springframework.cloud.stream.annotation.rxjava

Annotation that identifies the class as RxJava processor module.

entrySet() - Method in class org.springframework.cloud.stream.binder.MessageValues

equals(Object) - Method in class org.springframework.cloud.stream.binder.BinderType

errorChannelBindable(PublishSubscribeChannel) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

evaluationContext - Variable in class org.springframework.cloud.stream.binder.AbstractBinder

ExpressionSerializer - Class in org.springframework.cloud.stream.binder

JSON serializer for Expression value.

ExpressionSerializer() - Constructor for class org.springframework.cloud.stream.binder.ExpressionSerializer

ExtendedBindingProperties<C,P> - Interface in org.springframework.cloud.stream.binder

Properties that extend the common binding properties for a particular binder implementation.

ExtendedConsumerProperties<T> - Class in org.springframework.cloud.stream.binder

Extension of ConsumerProperties to be used with an ExtendedPropertiesBinder.

ExtendedConsumerProperties(T) - Constructor for class org.springframework.cloud.stream.binder.ExtendedConsumerProperties

ExtendedProducerProperties<T> - Class in org.springframework.cloud.stream.binder

ExtendedProducerProperties(T) - Constructor for class org.springframework.cloud.stream.binder.ExtendedProducerProperties

ExtendedPropertiesBinder<T,C,P> - Interface in org.springframework.cloud.stream.binder

Extension of Binder that takes ExtendedConsumerProperties and ExtendedProducerProperties as arguments.

extractHeaders(Message<byte[]>, boolean) - Method in class org.springframework.cloud.stream.binder.EmbeddedHeadersMessageConverter

Return a message where headers, that were originally embedded into the payload, have been promoted back to actual headers.

extractKey(Message<?>) - Method in interface org.springframework.cloud.stream.binder.PartitionKeyExtractorStrategy

extractMessageValues(Message<?>) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

Extract the message values from the the received message when the received message is embedded with header values.

F

fileRegistrar() - Method in class org.springframework.cloud.stream.config.codec.kryo.KryoCodecAutoConfiguration

from(Class<?>) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

G

get(String) - Method in class org.springframework.cloud.stream.aggregate.SharedChannelRegistry

get(String) - Method in interface org.springframework.cloud.stream.binder.BinderTypeRegistry

get(String) - Method in class org.springframework.cloud.stream.binder.DefaultBinderTypeRegistry

get(Object) - Method in class org.springframework.cloud.stream.binder.MessageValues

getAll() - Method in class org.springframework.cloud.stream.aggregate.SharedChannelRegistry

getAll() - Method in interface org.springframework.cloud.stream.binder.BinderTypeRegistry

getAll() - Method in class org.springframework.cloud.stream.binder.DefaultBinderTypeRegistry

getApplicationContext() - Method in class org.springframework.cloud.stream.binder.AbstractBinder

getBackOffInitialInterval() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

getBackOffMaxInterval() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

getBackOffMultiplier() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

getBeanFactory() - Method in class org.springframework.cloud.stream.binder.AbstractBinder

getBinder(String) - Method in interface org.springframework.cloud.stream.binder.BinderFactory

Returns the binder instance associated with the given configuration name.

getBinder(String) - Method in class org.springframework.cloud.stream.binder.DefaultBinderFactory

getBinder() - Method in class org.springframework.cloud.stream.config.BindingProperties

getBinder(String) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getBinders() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getBinderType() - Method in class org.springframework.cloud.stream.binder.BinderConfiguration

getBindingDestination(String) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getBindingProperties(String) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getBindings() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getChannelBindingServiceProperties() - Method in class org.springframework.cloud.stream.binding.ChannelBindingService

getChannelName(Annotation, Method) - Static method in class org.springframework.cloud.stream.binding.BindingBeanDefinitionRegistryUtils

getConcurrency() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

getConfigurationClasses() - Method in class org.springframework.cloud.stream.binder.BinderType

getConsumer() - Method in class org.springframework.cloud.stream.config.BindingProperties

getConsumerDefaults() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getConsumerProperties(String) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getContentType() - Method in class org.springframework.cloud.stream.config.BindingProperties

getDefaultBinder() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getDefaultName() - Method in class org.springframework.cloud.stream.binder.BinderType

getDestination() - Method in class org.springframework.cloud.stream.config.BindingProperties

getDynamicDestinations() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getEnvironment() - Method in class org.springframework.cloud.stream.config.BinderProperties

getExtendedConsumerProperties(String) - Method in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties

getExtendedProducerProperties(String) - Method in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties

getExtension() - Method in class org.springframework.cloud.stream.binder.ExtendedConsumerProperties

getExtension() - Method in class org.springframework.cloud.stream.binder.ExtendedProducerProperties

getFixedDelay() - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties

getGroup() - Method in class org.springframework.cloud.stream.binder.DefaultBinding

getGroup() - Method in class org.springframework.cloud.stream.config.BindingProperties

getGroup(String) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getHeaderMode() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

getHeaderMode() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

getInputs() - Method in interface org.springframework.cloud.stream.binding.Bindable

Enumerates all the input binding names.

getInputs() - Method in class org.springframework.cloud.stream.binding.BindableAdapter

getInputs() - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

getInputs() - Method in class org.springframework.cloud.stream.endpoint.ChannelsEndpoint.ChannelsMetaData

getInstanceCount() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

getInstanceCount() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getInstanceIndex() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

getInstanceIndex() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getJavaTypeForJavaObjectContentType(MimeType) - Static method in class org.springframework.cloud.stream.converter.MessageConverterUtils

Get the java Object type for the MimeType X_JAVA_OBJECT

getMaxAttempts() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

getMaxMessagesPerPoll() - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties

getMessageConverterForAllRegistered() - Method in class org.springframework.cloud.stream.converter.CompositeMessageConverterFactory

getMessageConverterForType(MimeType) - Method in class org.springframework.cloud.stream.converter.CompositeMessageConverterFactory

Creation method.

getMimeType(String) - Static method in class org.springframework.cloud.stream.converter.MessageConverterUtils

getName() - Method in class org.springframework.cloud.stream.binder.DefaultBinding

getObject() - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

getObjectType() - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

getOutputs() - Method in interface org.springframework.cloud.stream.binding.Bindable

Enumerates all the output binding names.

getOutputs() - Method in class org.springframework.cloud.stream.binding.BindableAdapter

getOutputs() - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

getOutputs() - Method in class org.springframework.cloud.stream.binding.DynamicDestinationsBindable

getOutputs() - Method in class org.springframework.cloud.stream.binding.SingleChannelBindable

getOutputs() - Method in class org.springframework.cloud.stream.endpoint.ChannelsEndpoint.ChannelsMetaData

getPartitionCount() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

getPartitionKeyExpression() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

getPartitionKeyExtractorClass() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

getPartitionSelectorClass() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

getPartitionSelectorExpression() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

getPayload() - Method in class org.springframework.cloud.stream.binder.MessageValues

getPhase() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

getPhase() - Method in class org.springframework.cloud.stream.binding.InputBindingLifecycle

Return a high value so that this bean is started after receiving Lifecycle beans are started.

getPhase() - Method in class org.springframework.cloud.stream.binding.OutputBindingLifecycle

Return a low value so that this bean is started after receiving Lifecycle beans are started.

getPollerMetadata() - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties

getProducer() - Method in class org.springframework.cloud.stream.config.BindingProperties

getProducerDefaults() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getProducerProperties(String) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

getProperties() - Method in class org.springframework.cloud.stream.binder.BinderConfiguration

getRequiredGroups() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

getType() - Method in class org.springframework.cloud.stream.config.BinderProperties

groupedName(String, String) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

Construct a name comprised of the name and group.

H

handleMessage(Message<?>) - Method in class org.springframework.cloud.stream.binder.DirectHandler

handleMessageInternal(Message<?>) - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

hashCode() - Method in class org.springframework.cloud.stream.binder.BinderType

HeaderMode - Enum in org.springframework.cloud.stream.binder

I

Input - Annotation Type in org.springframework.cloud.stream.annotation

Indicates that an input channel will be created by the framework.

INPUT - Static variable in interface org.springframework.cloud.stream.messaging.Sink

input() - Method in interface org.springframework.cloud.stream.messaging.Sink

InputBindingLifecycle - Class in org.springframework.cloud.stream.binding

Coordinates binding/unbinding of input channels in accordance to the lifecycle of the host context.

InputBindingLifecycle() - Constructor for class org.springframework.cloud.stream.binding.InputBindingLifecycle

inputBindingLifecycle() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

invoke(MethodInvocation) - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

invoke() - Method in class org.springframework.cloud.stream.endpoint.ChannelsEndpoint

isAutoStartup() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

isAutoStartup() - Method in class org.springframework.cloud.stream.binding.InputBindingLifecycle

isAutoStartup() - Method in class org.springframework.cloud.stream.binding.OutputBindingLifecycle

isDefaultCandidate() - Method in class org.springframework.cloud.stream.binder.BinderConfiguration

isDefaultCandidate() - Method in class org.springframework.cloud.stream.config.BinderProperties

isEmpty() - Method in class org.springframework.cloud.stream.binder.MessageValues

isIgnoreUnknownProperties() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

isInheritEnvironment() - Method in class org.springframework.cloud.stream.binder.BinderConfiguration

isInheritEnvironment() - Method in class org.springframework.cloud.stream.config.BinderProperties

isPartitioned() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

isPartitioned() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

isReferences() - Method in class org.springframework.cloud.stream.config.codec.kryo.KryoCodecProperties

isRunning() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

isRunning() - Method in class org.springframework.cloud.stream.binding.InputBindingLifecycle

isRunning() - Method in class org.springframework.cloud.stream.binding.OutputBindingLifecycle

isSingleton() - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

isValidPartitionKeyProperty() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

Gets the value of the property validPartitionKeyProperty.

isValidPartitionSelectorProperty() - Method in class org.springframework.cloud.stream.binder.ProducerProperties

Gets the value of the property validPartitionSelectorProperty.

J

JavaClassMimeTypeConversion() - Constructor for class org.springframework.cloud.stream.binder.AbstractBinder.JavaClassMimeTypeConversion

javaObjectMimeType(Class<?>) - Static method in class org.springframework.cloud.stream.converter.MessageConverterUtils

Build the conventional MimeType for a java object

JavaToSerializedMessageConverter - Class in org.springframework.cloud.stream.converter

A MessageConverter to convert from a POJO to byte[] with Java.io serialization if any.

JavaToSerializedMessageConverter() - Constructor for class org.springframework.cloud.stream.converter.JavaToSerializedMessageConverter

JsonToPojoMessageConverter - Class in org.springframework.cloud.stream.converter

JsonToPojoMessageConverter(ObjectMapper) - Constructor for class org.springframework.cloud.stream.converter.JsonToPojoMessageConverter

JsonToTupleMessageConverter - Class in org.springframework.cloud.stream.converter

A MessageConverter to convert from a JSON (byte[] or String) to a Tuple.

JsonToTupleMessageConverter() - Constructor for class org.springframework.cloud.stream.converter.JsonToTupleMessageConverter

K

keySet() - Method in class org.springframework.cloud.stream.binder.MessageValues

KryoCodecAutoConfiguration - Class in org.springframework.cloud.stream.config.codec.kryo

Auto configures PojoCodec if Kryo is on the class path.

KryoCodecAutoConfiguration() - Constructor for class org.springframework.cloud.stream.config.codec.kryo.KryoCodecAutoConfiguration

KryoCodecProperties - Class in org.springframework.cloud.stream.config.codec.kryo

KryoCodecProperties() - Constructor for class org.springframework.cloud.stream.config.codec.kryo.KryoCodecProperties

L

logger - Variable in class org.springframework.cloud.stream.binder.AbstractBinder

logger - Variable in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

M

MessageChannelConfigurer - Interface in org.springframework.cloud.stream.binding

Interface to be implemented by the classes that configure the Bindable message channels.

MessageConverterConfigurer - Class in org.springframework.cloud.stream.binding

A MessageChannelConfigurer that sets data types and message converters based on BindingProperties.contentType.

MessageConverterConfigurer(ChannelBindingServiceProperties, MessageBuilderFactory, CompositeMessageConverterFactory) - Constructor for class org.springframework.cloud.stream.binding.MessageConverterConfigurer

messageConverterConfigurer(ChannelBindingServiceProperties, MessageBuilderFactory, CompositeMessageConverterFactory) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

MessageConverterUtils - Class in org.springframework.cloud.stream.converter

Message conversion utility methods.

MessageConverterUtils() - Constructor for class org.springframework.cloud.stream.converter.MessageConverterUtils

messageHandlerMethodFactory(CompositeMessageConverterFactory) - Static method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

MessageValues - Class in org.springframework.cloud.stream.binder

A mutable type for allowing Binder implementations to transform and enrich message content more efficiently.

MessageValues(Message<?>) - Constructor for class org.springframework.cloud.stream.binder.MessageValues

Create an instance from a Message.

MessageValues(Object, Map<String, Object>) - Constructor for class org.springframework.cloud.stream.binder.MessageValues

N

namespace(String) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer

O

onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.cloud.stream.binding.ContextStartAfterRefreshListener

onInit() - Method in class org.springframework.cloud.stream.binder.AbstractBinder

Subclasses may implement this method to perform any necessary initialization.

onlyOneOfProducerOrConsumerSet() - Method in class org.springframework.cloud.stream.config.BindingProperties

org.springframework.cloud.stream.aggregate - package org.springframework.cloud.stream.aggregate

org.springframework.cloud.stream.annotation - package org.springframework.cloud.stream.annotation

org.springframework.cloud.stream.annotation.rxjava - package org.springframework.cloud.stream.annotation.rxjava

org.springframework.cloud.stream.binder - package org.springframework.cloud.stream.binder

org.springframework.cloud.stream.binding - package org.springframework.cloud.stream.binding

org.springframework.cloud.stream.config - package org.springframework.cloud.stream.config

org.springframework.cloud.stream.config.codec.kryo - package org.springframework.cloud.stream.config.codec.kryo

org.springframework.cloud.stream.converter - package org.springframework.cloud.stream.converter

Package for message converters.

org.springframework.cloud.stream.endpoint - package org.springframework.cloud.stream.endpoint

org.springframework.cloud.stream.messaging - package org.springframework.cloud.stream.messaging

Output - Annotation Type in org.springframework.cloud.stream.annotation

Indicates that an output channel will be created by the framework.

OUTPUT - Static variable in interface org.springframework.cloud.stream.messaging.Source

output() - Method in interface org.springframework.cloud.stream.messaging.Source

OutputBindingLifecycle - Class in org.springframework.cloud.stream.binding

Coordinates binding/unbinding of output channels in accordance to the lifecycle of the host context.

OutputBindingLifecycle() - Constructor for class org.springframework.cloud.stream.binding.OutputBindingLifecycle

outputBindingLifecycle() - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration

P

parent(Object, String...) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

parent(Object[], String[]) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

parent(ConfigurableApplicationContext) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

PARTITION_HEADER - Static variable in class org.springframework.cloud.stream.binder.AbstractBinder

PartitionHandler - Class in org.springframework.cloud.stream.binder

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.

PartitionHandler(ConfigurableListableBeanFactory, EvaluationContext, PartitionSelectorStrategy, ProducerProperties) - Constructor for class org.springframework.cloud.stream.binder.PartitionHandler

Construct a PartitionHandler.

PartitionKeyExtractorStrategy - Interface in org.springframework.cloud.stream.binder

Strategy for extracting a partition key from a Message.

partitionSelector - Variable in class org.springframework.cloud.stream.binder.AbstractBinder

PartitionSelectorStrategy - Interface in org.springframework.cloud.stream.binder

Strategy for determining the partition to which a message should be sent.

PojoToJsonMessageConverter - Class in org.springframework.cloud.stream.converter

A MessageConverter to convert a Java object to a JSON String

PojoToJsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.cloud.stream.converter.PojoToJsonMessageConverter

PojoToStringMessageConverter - Class in org.springframework.cloud.stream.converter

A MessageConverter to convert a Java object to a String using toString()

PojoToStringMessageConverter() - Constructor for class org.springframework.cloud.stream.converter.PojoToStringMessageConverter

postProcessAfterInitialization(Object, String) - Method in class org.springframework.cloud.stream.binding.BinderAwareRouterBeanPostProcessor

postProcessAfterInitialization(Object, String) - Method in class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor

postProcessBeforeInitialization(Object, String) - Method in class org.springframework.cloud.stream.binding.BinderAwareRouterBeanPostProcessor

postProcessBeforeInitialization(Object, String) - Method in class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor

PostProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration.PostProcessorConfiguration

process(Observable<I>) - Method in interface org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessor

Processor - Interface in org.springframework.cloud.stream.messaging

Bindable interface with one input and one output channel.

ProcessorConfigurer(Class<?>) - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.ProcessorConfigurer

ProducerProperties - Class in org.springframework.cloud.stream.binder

Common producer properties.

ProducerProperties() - Constructor for class org.springframework.cloud.stream.binder.ProducerProperties

profiles(String...) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer

propertyAccessorBeanPostProcessor() - Static method in class org.springframework.cloud.stream.config.ChannelBindingServiceConfiguration.PostProcessorConfiguration

Adds property accessors for use in SpEL expression evaluation

put(String, Object) - Method in class org.springframework.cloud.stream.binder.MessageValues

putAll(Map<? extends String, ?>) - Method in class org.springframework.cloud.stream.binder.MessageValues

R

register(String, MessageChannel) - Method in class org.springframework.cloud.stream.aggregate.SharedChannelRegistry

registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.cloud.stream.config.BindingBeansRegistrar

registerChannelBeanDefinitions(Class<?>, String, BeanDefinitionRegistry) - Static method in class org.springframework.cloud.stream.binding.BindingBeanDefinitionRegistryUtils

registerChannelsQualifiedBeanDefinitions(Class<?>, Class<?>, BeanDefinitionRegistry) - Static method in class org.springframework.cloud.stream.binding.BindingBeanDefinitionRegistryUtils

registerInputChannelBeanDefinition(String, String, String, String, BeanDefinitionRegistry) - Static method in class org.springframework.cloud.stream.binding.BindingBeanDefinitionRegistryUtils

registerOutputChannelBeanDefinition(String, String, String, String, BeanDefinitionRegistry) - Static method in class org.springframework.cloud.stream.binding.BindingBeanDefinitionRegistryUtils

remove(Object) - Method in class org.springframework.cloud.stream.binder.MessageValues

resolve(MessageHeaders) - Method in class org.springframework.cloud.stream.binder.StringConvertingContentTypeResolver

resolve(Map<String, Object>) - Method in class org.springframework.cloud.stream.binder.StringConvertingContentTypeResolver

resolveContentType(String) - Static method in class org.springframework.cloud.stream.converter.MessageConverterUtils

resolveDestination(String) - Method in class org.springframework.cloud.stream.binding.BinderAwareChannelResolver

resolveJavaType(String) - Static method in class org.springframework.cloud.stream.converter.MessageConverterUtils

run(String...) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer

run(String[]) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

RxJavaProcessor<I,O> - Interface in org.springframework.cloud.stream.annotation.rxjava

Marker interface that RxJava processor module uses to provide the implementation bean.

RxJavaProcessorConfiguration - Class in org.springframework.cloud.stream.annotation.rxjava

Configuration class for RxJava module support.

RxJavaProcessorConfiguration() - Constructor for class org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessorConfiguration

S

selectPartition(Object, int) - Method in interface org.springframework.cloud.stream.binder.PartitionSelectorStrategy

Determine the partition based on a key.

serialize(Expression, JsonGenerator, SerializerProvider) - Method in class org.springframework.cloud.stream.binder.ExpressionSerializer

SerializedToJavaMessageConverter - Class in org.springframework.cloud.stream.converter

A MessageConverter to deserialize Serializable Java objects.

SerializedToJavaMessageConverter() - Constructor for class org.springframework.cloud.stream.converter.SerializedToJavaMessageConverter

serializePayloadIfNecessary(Message<?>) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

setApplicationContext(ApplicationContext) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

setApplicationContext(ApplicationContext) - Method in class org.springframework.cloud.stream.binder.DefaultBinderFactory

setApplicationContext(ApplicationContext) - Method in class org.springframework.cloud.stream.binding.ContextStartAfterRefreshListener

setApplicationContext(ApplicationContext) - Method in class org.springframework.cloud.stream.binding.InputBindingLifecycle

setApplicationContext(ApplicationContext) - Method in class org.springframework.cloud.stream.binding.OutputBindingLifecycle

setApplicationContext(ApplicationContext) - Method in class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor

setApplicationContext(ApplicationContext) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setBackOffInitialInterval(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setBackOffMaxInterval(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setBackOffMultiplier(double) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setBeanFactory(BeanFactory) - Method in class org.springframework.cloud.stream.binding.BinderAwareChannelResolver

setBeanFactory(BeanFactory) - Method in class org.springframework.cloud.stream.binding.MessageConverterConfigurer

setBinder(String) - Method in class org.springframework.cloud.stream.config.BindingProperties

setBinders(Map<String, BinderProperties>) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setBindersHealthIndicator(CompositeHealthIndicator) - Method in class org.springframework.cloud.stream.binder.DefaultBinderFactory

setBindings(Map<String, BindingProperties>) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setCodec(Codec) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

setConcurrency(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setConsumer(ConsumerProperties) - Method in class org.springframework.cloud.stream.config.BindingProperties

setConsumerDefaults(Properties) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setContentType(String) - Method in class org.springframework.cloud.stream.config.BindingProperties

setDefaultBinder(String) - Method in class org.springframework.cloud.stream.binder.DefaultBinderFactory

setDefaultBinder(String) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setDefaultCandidate(boolean) - Method in class org.springframework.cloud.stream.config.BinderProperties

setDestination(String) - Method in class org.springframework.cloud.stream.config.BindingProperties

setDynamicDestinations(String[]) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setEnvironment(Properties) - Method in class org.springframework.cloud.stream.config.BinderProperties

setFixedDelay(long) - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties

setGroup(String) - Method in class org.springframework.cloud.stream.config.BindingProperties

setHeaderMode(HeaderMode) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setHeaderMode(HeaderMode) - Method in class org.springframework.cloud.stream.binder.ProducerProperties

setIgnoreUnknownProperties(boolean) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setInheritEnvironment(boolean) - Method in class org.springframework.cloud.stream.config.BinderProperties

setInstanceCount(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setInstanceCount(int) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setInstanceIndex(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setInstanceIndex(int) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setIntegrationEvaluationContext(EvaluationContext) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

setMaxAttempts(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setMaxMessagesPerPoll(long) - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties

setPartitionCount(int) - Method in class org.springframework.cloud.stream.binder.ProducerProperties

setPartitioned(boolean) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties

setPartitionKeyExpression(Expression) - Method in class org.springframework.cloud.stream.binder.ProducerProperties

setPartitionKeyExtractorClass(Class<?>) - Method in class org.springframework.cloud.stream.binder.ProducerProperties

setPartitionSelector(PartitionSelectorStrategy) - Method in class org.springframework.cloud.stream.binder.AbstractBinder

Set the partition strategy to be used by this binder if no partitionExpression is provided for a module.

setPartitionSelectorClass(Class<?>) - Method in class org.springframework.cloud.stream.binder.ProducerProperties

setPartitionSelectorExpression(Expression) - Method in class org.springframework.cloud.stream.binder.ProducerProperties

setPayload(Object) - Method in class org.springframework.cloud.stream.binder.MessageValues

Set the payload

setPrettyPrint(boolean) - Method in class org.springframework.cloud.stream.converter.PojoToJsonMessageConverter

setPrettyPrint(boolean) - Method in class org.springframework.cloud.stream.converter.TupleToJsonMessageConverter

setProducer(ProducerProperties) - Method in class org.springframework.cloud.stream.config.BindingProperties

setProducerDefaults(Properties) - Method in class org.springframework.cloud.stream.config.ChannelBindingServiceProperties

setReferences(boolean) - Method in class org.springframework.cloud.stream.config.codec.kryo.KryoCodecProperties

setRequiredGroups(String...) - Method in class org.springframework.cloud.stream.binder.ProducerProperties

setType(String) - Method in class org.springframework.cloud.stream.config.BinderProperties

sharedChannelRegistry() - Method in class org.springframework.cloud.stream.aggregate.AggregatorParentConfiguration

SharedChannelRegistry - Class in org.springframework.cloud.stream.aggregate

A registry for channels that can be shared between modules, used for module aggregation.

SharedChannelRegistry() - Constructor for class org.springframework.cloud.stream.aggregate.SharedChannelRegistry

SingleChannelBindable - Class in org.springframework.cloud.stream.binding

A Bindable component that wraps a generic channel.

SingleChannelBindable(String, MessageChannel) - Constructor for class org.springframework.cloud.stream.binding.SingleChannelBindable

Sink - Interface in org.springframework.cloud.stream.messaging

Bindable interface with one input channel.

SinkConfigurer(Class<?>) - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.SinkConfigurer

size() - Method in class org.springframework.cloud.stream.binder.MessageValues

Source - Interface in org.springframework.cloud.stream.messaging

Bindable interface with one output channel.

SourceConfigurer(Class<?>) - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.SourceConfigurer

spelConverter() - Method in class org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration

SpelConverter() - Constructor for class org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration.SpelConverter

SpelExpressionConverterConfiguration - Class in org.springframework.cloud.stream.config

Adds a Converter from String to SpEL Expression in the context.

SpelExpressionConverterConfiguration() - Constructor for class org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration

SpelExpressionConverterConfiguration.SpelConverter - Class in org.springframework.cloud.stream.config

A simple converter from String to Expression.

STANDARD_HEADERS - Static variable in class org.springframework.cloud.stream.binder.BinderHeaders

The headers that will be propagated, by default, by binder implementations that have no inherent header support (by embedding the headers in the payload).

start() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

start() - Method in class org.springframework.cloud.stream.binding.InputBindingLifecycle

start() - Method in class org.springframework.cloud.stream.binding.OutputBindingLifecycle

stop(Runnable) - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

stop() - Method in class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

stop() - Method in class org.springframework.cloud.stream.binding.InputBindingLifecycle

stop(Runnable) - Method in class org.springframework.cloud.stream.binding.InputBindingLifecycle

stop() - Method in class org.springframework.cloud.stream.binding.OutputBindingLifecycle

stop(Runnable) - Method in class org.springframework.cloud.stream.binding.OutputBindingLifecycle

StreamListener - Annotation Type in org.springframework.cloud.stream.annotation

Annotation that marks a method to be a listener to an input component declared through EnableBinding (e.g.

StreamListenerAnnotationBeanPostProcessor - Class in org.springframework.cloud.stream.binding

BeanPostProcessor that handles StreamListener annotations found on bean methods.

StreamListenerAnnotationBeanPostProcessor(DestinationResolver<MessageChannel>, MessageHandlerMethodFactory) - Constructor for class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor

StringConvertingContentTypeResolver - Class in org.springframework.cloud.stream.binder

A DefaultContentTypeResolver that can parse String values.

StringConvertingContentTypeResolver() - Constructor for class org.springframework.cloud.stream.binder.StringConvertingContentTypeResolver

StringToByteArrayMessageConverter - Class in org.springframework.cloud.stream.converter

A MessageConverter to convert a String to a byte[], applying the provided Charset in the content-type header if any.

StringToByteArrayMessageConverter() - Constructor for class org.springframework.cloud.stream.converter.StringToByteArrayMessageConverter

subjectMessageHandler() - Method in class org.springframework.cloud.stream.annotation.rxjava.RxJavaProcessorConfiguration

SubjectMessageHandler - Class in org.springframework.cloud.stream.annotation.rxjava

Adapts the item at a time delivery of a MessageHandler by delegating processing to a Observable.

SubjectMessageHandler(RxJavaProcessor) - Constructor for class org.springframework.cloud.stream.annotation.rxjava.SubjectMessageHandler

supportedDataTypes(MimeType) - Method in class org.springframework.cloud.stream.converter.CompositeMessageConverterFactory

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Subclasses implement this to specify supported payload types

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.ByteArrayToStringMessageConverter

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.JavaToSerializedMessageConverter

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.JsonToPojoMessageConverter

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.JsonToTupleMessageConverter

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.PojoToJsonMessageConverter

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.PojoToStringMessageConverter

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.SerializedToJavaMessageConverter

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.StringToByteArrayMessageConverter

supportedPayloadTypes() - Method in class org.springframework.cloud.stream.converter.TupleToJsonMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

Subclasses implement this to specify supported target types

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.ByteArrayToStringMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.JavaToSerializedMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.JsonToPojoMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.JsonToTupleMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.PojoToJsonMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.PojoToStringMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.SerializedToJavaMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.StringToByteArrayMessageConverter

supportedTargetTypes() - Method in class org.springframework.cloud.stream.converter.TupleToJsonMessageConverter

supports(Class<?>) - Method in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

supportsPayloadType(Class<?>) - Method in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

supportsTargetMimeType(MimeType) - Method in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

T

targetMimeTypes - Variable in class org.springframework.cloud.stream.converter.AbstractFromMessageConverter

to(Class<?>) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.ProcessorConfigurer

to(Class<?>) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.SourceConfigurer

toMessage(MessageBuilderFactory) - Method in class org.springframework.cloud.stream.binder.MessageValues

Convert to a Message using a MessageBuilderFactory.

toMessage() - Method in class org.springframework.cloud.stream.binder.MessageValues

Convert to a Message using a the default MessageBuilder.

toString() - Method in class org.springframework.cloud.stream.binder.DefaultBinding

toString() - Method in class org.springframework.cloud.stream.config.BindingProperties

TupleToJsonMessageConverter - Class in org.springframework.cloud.stream.converter

A MessageConverter to convert a Tuple to a JSON String

TupleToJsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.cloud.stream.converter.TupleToJsonMessageConverter

U

unbind() - Method in interface org.springframework.cloud.stream.binder.Binding

Unbinds the target component represented by this instance and stops any active components.

unbind() - Method in class org.springframework.cloud.stream.binder.DefaultBinding

unbindConsumers(String) - Method in class org.springframework.cloud.stream.binding.ChannelBindingService

unbindInputs(ChannelBindingService) - Method in interface org.springframework.cloud.stream.binding.Bindable

Unbinds all the inputs associated with this instance.

unbindInputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.BindableAdapter

unbindInputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

unbindOutputs(ChannelBindingService) - Method in interface org.springframework.cloud.stream.binding.Bindable

Unbinds all the outputs associated with this instance.

unbindOutputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.BindableAdapter

unbindOutputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory

unbindOutputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.DynamicDestinationsBindable

unbindOutputs(ChannelBindingService) - Method in class org.springframework.cloud.stream.binding.SingleChannelBindable

unbindProducers(String) - Method in class org.springframework.cloud.stream.binding.ChannelBindingService

V

valueOf(String) - Static method in enum org.springframework.cloud.stream.binder.HeaderMode

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.springframework.cloud.stream.binder.HeaderMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Method in class org.springframework.cloud.stream.binder.MessageValues

via(Class<?>) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.ProcessorConfigurer

via(Class<?>) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.SourceConfigurer

X

X_JAVA_OBJECT - Static variable in class org.springframework.cloud.stream.converter.MessageConverterUtils

A general MimeType for Java Types.

X_JAVA_SERIALIZED_OBJECT - Static variable in class org.springframework.cloud.stream.converter.MessageConverterUtils

A general MimeType for a Java serialized byte array.

X_SPRING_TUPLE - Static variable in class org.springframework.cloud.stream.converter.MessageConverterUtils

An MimeType specifying a Tuple.

A B C D E F G H I J K L M N O P R S T U V X