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

A

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

Base class for Binder implementations.

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.

AbstractBindingTargetFactory<T> - Class in org.springframework.cloud.stream.binding

A BindingTargetFactory implementation that restricts the type of binding target to a specified class and its supertypes.

AbstractBindingTargetFactory(Class<T>) - Constructor for class org.springframework.cloud.stream.binding.AbstractBindingTargetFactory

AbstractMessageChannelBinder<C extends ConsumerProperties,P extends ProducerProperties,CD,PD> - Class in org.springframework.cloud.stream.binder

AbstractBinder that serves as base class for MessageChannel binders.

AbstractMessageChannelBinder(boolean, String[]) - Constructor for class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

adapt(MessageChannel, MessageChannel) - Method in class org.springframework.cloud.stream.binding.MessageChannelStreamListenerResultAdapter

adapt(B, MethodParameter) - Method in interface org.springframework.cloud.stream.binding.StreamListenerParameterAdapter

Adapts the binding target to the argument type.

adapt(R, B) - Method in interface org.springframework.cloud.stream.binding.StreamListenerResultAdapter

Adapts the result to the binding target.

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

AdminUtilsOperation - Interface in org.springframework.cloud.stream.binder.kafka.admin

API around AdminUtils to support various versions of Kafka brokers.

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.BindingServiceProperties

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

Deprecated.

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

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

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

Listener method that executes after unbinding.

afterUnbindConsumer(String, String, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

Invoked after the unbinding of a consumer.

afterUnbindConsumer(String, String, ExtendedConsumerProperties<RabbitConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

afterUnbindProducer(String, P) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

Invoked after the unbinding of a producer.

AggregateApplication - Interface in org.springframework.cloud.stream.aggregate

Handle to an aggregate application, providing access to the underlying components of the aggregate (e.g.

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

Application builder for AggregateApplication.

AggregateApplicationBuilder(String...) - 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.AppConfigurer<T extends AggregateApplicationBuilder.AppConfigurer<T>> - Class in org.springframework.cloud.stream.aggregate

AggregateApplicationBuilder.ParentConfiguration - 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

AMBIGUOUS_MESSAGE_HANDLER_METHOD_ARGUMENTS - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

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.BindingServiceProperties

Return configuration properties as Map.

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

Deprecated.

ATLEAST_ONE_OUTPUT - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

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

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(T, String) - Method in class org.springframework.cloud.stream.binding.BindingService

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

Indicates the original content type of a message that has been transformed in a native transport format.

BINDER_PREFIX - Static variable in class org.springframework.cloud.stream.binder.rabbit.RabbitBindingCleaner

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(BindingService, AbstractBindingTargetFactory<? extends MessageChannel>, DynamicDestinationsBindable) - Constructor for class org.springframework.cloud.stream.binding.BinderAwareChannelResolver

binderAwareChannelResolver(BindingService, AbstractBindingTargetFactory<? extends MessageChannel>, DynamicDestinationsBindable) - Method in class org.springframework.cloud.stream.config.BindingServiceConfiguration

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.BindingServiceConfiguration.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 - Interface in org.springframework.cloud.stream.binder

binderFactory(BinderTypeRegistry, BindingServiceProperties) - 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.

binderHealthIndicator(RabbitTemplate) - Method in class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration

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 binding targets.

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

Deprecated.

As of 1.1 for being redundant (beans qualified by it are already uniquely identified by their type)

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

Handles binding of input/output targets by delegating to an underlying Binder.

BindingService(BindingServiceProperties, BinderFactory) - Constructor for class org.springframework.cloud.stream.binding.BindingService

bindingService(BindingServiceProperties, BinderFactory) - Method in class org.springframework.cloud.stream.config.BindingServiceConfiguration

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

Configuration class that provides necessary beans for MessageChannel binding.

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

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

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

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

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

Defines methods to create/configure the binding targets defined by EnableBinding.

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

Binds all the inputs associated with this instance.

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

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

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

Binds all the outputs associated with this instance.

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

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

bindOutputs(BindingService) - Method in class org.springframework.cloud.stream.binding.SingleBindingTargetBindable

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(T, String) - Method in class org.springframework.cloud.stream.binding.BindingService

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

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

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

buildRestTemplate(String, String, String) - Static method in class org.springframework.cloud.stream.binder.rabbit.RabbitManagementUtils

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

Create and configure a retry template.

C

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

canCreate(Class<?>) - Method in class org.springframework.cloud.stream.binding.AbstractBindingTargetFactory

canCreate(Class<?>) - Method in interface org.springframework.cloud.stream.binding.BindingTargetFactory

Checks whether a specific binding target type can be created by this factory.

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

channelBindingServiceProperties(BindingServiceProperties) - Method in class org.springframework.cloud.stream.config.BindingServiceConfiguration

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

Deprecated.

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

Deprecated.

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

channelsEndpoint(BindingServiceProperties) - 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>, BindingServiceProperties) - 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.

clean(String, boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitBindingCleaner

clean(String, String, String, String, String, String, boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitBindingCleaner

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

cloud() - Method in class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration.CloudProfile.CloudConnectors

CloudConnectors() - Constructor for class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration.CloudProfile.CloudConnectors

CloudProfile() - Constructor for class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration.CloudProfile

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.BindingServiceConfiguration

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

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 MessageConverter>, ObjectMapper) - Constructor for class org.springframework.cloud.stream.converter.CompositeMessageConverterFactory

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

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

Configure the given input message channel.

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

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

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

Configure the given output message channel.

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

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

containsKey(Object) - Method in class org.springframework.cloud.stream.config.EnvironmentEntryInitializingTreeMap

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.BindingServiceConfiguration

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.JavaSerializationMessageConverter

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

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

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

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

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

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

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

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

count() - Method in class org.springframework.cloud.stream.aggregate.NamespaceAwareSpringIntegrationMetricReader

createConsumerDestinationIfNecessary(String, String, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

Creates the middleware destination the consumer will start to consume data from.

createConsumerDestinationIfNecessary(String, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

createConsumerDestinationIfNecessary(String, String, ExtendedConsumerProperties<RabbitConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

createConsumerEndpoint(String, String, CD, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

Creates MessageProducer that receives data from the consumer destination.

createConsumerEndpoint(String, String, Collection<PartitionInfo>, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

createConsumerEndpoint(String, String, Queue, ExtendedConsumerProperties<RabbitConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

createInput(String) - Method in class org.springframework.cloud.stream.binding.AbstractBindingTargetFactory

createInput(String) - Method in interface org.springframework.cloud.stream.binding.BindingTargetFactory

Create an input binding target that will be bound via a corresponding Binder.

createInput(String) - Method in class org.springframework.cloud.stream.binding.SubscribableChannelBindingTargetFactory

createOutput(String) - Method in class org.springframework.cloud.stream.binding.AbstractBindingTargetFactory

createOutput(String) - Method in interface org.springframework.cloud.stream.binding.BindingTargetFactory

Create an output binding target that will be bound via a corresponding Binder.

createOutput(String) - Method in class org.springframework.cloud.stream.binding.SubscribableChannelBindingTargetFactory

createProducerDestinationIfNecessary(String, P) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

Creates target destinations for outbound channels.

createProducerDestinationIfNecessary(String, ExtendedProducerProperties<KafkaProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

createProducerDestinationIfNecessary(String, ExtendedProducerProperties<RabbitProducerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

createProducerMessageHandler(PD, P) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

Creates a MessageHandler with the ability to send data to the target middleware.

createProducerMessageHandler(String, ExtendedProducerProperties<KafkaProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

createProducerMessageHandler(Exchange, ExtendedProducerProperties<RabbitProducerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

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

DEFAULT_ZK_LOGIN_CONTEXT_NAME - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderJaasInitializerListener

DefaultBinderFactory - 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, Lifecycle) - Constructor for class org.springframework.cloud.stream.binder.DefaultBinding

Creates an instance that associates a given name, group and binding target with an optional Lifecycle component, which will be stopped during unbinding.

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

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

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

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

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

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

Binds an inbound channel to a given destination.

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

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

Binds an outbound channel to a given destination.

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.BindingServiceConfiguration

E

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 targets 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

Deprecated.

in favor of StreamListener with reactive types

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

entrySet() - Method in class org.springframework.cloud.stream.config.EnvironmentEntryInitializingTreeMap

EnvironmentEntryInitializingTreeMap<T> - Class in org.springframework.cloud.stream.config

A Map implementation that initializes its entries by binding values from the supplied environment.

EnvironmentEntryInitializingTreeMap(ConfigurableEnvironment, Class<T>, String, Map<String, T>) - Constructor for class org.springframework.cloud.stream.config.EnvironmentEntryInitializingTreeMap

Constructs the map.

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

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

errorCodeFromTopicMetadata(String, ZkUtils) - Method in interface org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation

Invoke AdminUtils.fetchTopicMetadataFromZk(scala.collection.Set<java.lang.String>, kafka.utils.ZkUtils)

errorCodeFromTopicMetadata(String, ZkUtils) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation

errorCodeFromTopicMetadata(String, ZkUtils) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation

EXPRESSION_PARSER - Static variable in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

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.

extractHeaders(byte[]) - 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

F

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

findAll() - Method in class org.springframework.cloud.stream.aggregate.NamespaceAwareSpringIntegrationMetricReader

findOne(String) - Method in class org.springframework.cloud.stream.aggregate.NamespaceAwareSpringIntegrationMetricReader

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

G

GenericsUtils - Class in org.springframework.cloud.stream.reflection

Internal utilities for handling generics.

GenericsUtils() - Constructor for class org.springframework.cloud.stream.reflection.GenericsUtils

get(String, Class<T>) - Method in class org.springframework.cloud.stream.aggregate.SharedBindingTargetRegistry

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

Deprecated.

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

get(Object) - Method in class org.springframework.cloud.stream.config.EnvironmentEntryInitializingTreeMap

getAcknowledgeMode() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

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

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

Deprecated.

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

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

getAppConfigurationEntry(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderJaasInitializerListener.InternalConfiguration

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

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

getAutoCommitOnError() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

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

getBatchBufferLimit() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

getBatchSize() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

getBatchTimeout() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

getBatchTimeout() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

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

getBinder(String, Class<? extends T>) - Method in interface org.springframework.cloud.stream.binder.BinderFactory

Returns the binder instance associated with the given configuration name.

getBinder(String, Class<? extends T>) - 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.BindingServiceProperties

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

Deprecated.

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

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

Deprecated.

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

getBinding(Class<T>, String) - Method in interface org.springframework.cloud.stream.aggregate.AggregateApplication

Retrieves the bindable proxy instance (e.g.

getBinding(Class<T>, String) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

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

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

Deprecated.

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

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

Deprecated.

getBindingRoutingKey() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

getBindings() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties

getBindings() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitExtendedBindingProperties

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

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

Deprecated.

getBindingServiceProperties() - Method in class org.springframework.cloud.stream.binding.BindingService

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

getBrokers() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getBufferSize() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

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

Deprecated.

getCompressionType() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

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

getConfiguration() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getConfiguration() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

getConfiguration() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

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

getConsumer() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties

getConsumer() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitBindingProperties

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

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

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

Deprecated.

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

getControlFlag() - Method in class org.springframework.cloud.stream.binder.kafka.config.JaasLoginModuleConfiguration

getControlFlagValue() - Method in class org.springframework.cloud.stream.binder.kafka.config.JaasLoginModuleConfiguration

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

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

Deprecated.

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

getDelayExpression() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

getDeliveryMode() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

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

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

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

Deprecated.

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

getExchangeType() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

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

getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties

getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitExtendedBindingProperties

getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

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

getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties

getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitExtendedBindingProperties

getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

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

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

getFetchSize() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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.BindingServiceProperties

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

Deprecated.

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

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

getHeaders() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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

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.BindingServiceProperties

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

Deprecated.

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

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

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

Deprecated.

getJaas() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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

Get the java Object type for the MimeType X_JAVA_OBJECT

getKafkaConnectionString() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getLoginModule() - Method in class org.springframework.cloud.stream.binder.kafka.config.JaasLoginModuleConfiguration

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

getMaxConcurrency() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

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

getMaxWait() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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

getMinPartitionCount() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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

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

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

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

getOffsetUpdateCount() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getOffsetUpdateShutdownTimeout() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getOffsetUpdateTimeWindow() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getOptions() - Method in class org.springframework.cloud.stream.binder.kafka.config.JaasLoginModuleConfiguration

getOutboundBindingTargetName(Method) - Static method in class org.springframework.cloud.stream.binding.StreamListenerMethodUtils

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.SingleBindingTargetBindable

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

getParameterType(Class<?>, Class<?>, int) - Static method in class org.springframework.cloud.stream.reflection.GenericsUtils

For a specific class that implements or extends a parametrized type returns the parameter of that interface at a given position.

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

Deprecated.

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

getPrefetch() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

getPrefix() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

getPrefix() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

getProducer() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties

getProducer() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitBindingProperties

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

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

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

Deprecated.

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

getQueueSize() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getRecoveryInterval() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

getRecoveryInterval() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

getReferencePoint() - Method in enum org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties.StartOffset

getReplicationFactor() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getReplyHeaderPatterns() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

getReplyHeaderPatterns() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

getRequestHeaderPatterns() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

getRequestHeaderPatterns() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

getRequiredAcks() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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

getRoutingKeyExpression() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

getSocketBufferSize() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getStartOffset() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

getTxSize() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

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

getZkConnectionString() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getZkConnectionTimeout() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getZkNodes() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

getZkSessionTimeout() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

group - Variable in class org.springframework.cloud.stream.binder.DefaultBinding

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

Deprecated.

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

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

headless(boolean) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

Configures the headless attribute of the build application.

health() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderHealthIndicator

I

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

Indicates that an input binding target 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

INPUT_AT_STREAM_LISTENER - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

inputAnnotationCount(Method) - Static method in class org.springframework.cloud.stream.binding.StreamListenerMethodUtils

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

Coordinates binding/unbinding of input binding targets 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.BindingServiceConfiguration

InternalConfiguration(Map<String, AppConfigurationEntry[]>) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderJaasInitializerListener.InternalConfiguration

InternalPropertyNames - Class in org.springframework.cloud.stream.internal

Contains the names of properties for the internal use of Spring Cloud Stream.

InternalPropertyNames() - Constructor for class org.springframework.cloud.stream.internal.InternalPropertyNames

INVALID_DECLARATIVE_METHOD_PARAMETERS - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

INVALID_INBOUND_NAME - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

INVALID_INPUT_OUTPUT_METHOD_PARAMETERS - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

INVALID_INPUT_VALUE_WITH_OUTPUT_METHOD_PARAM - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

INVALID_INPUT_VALUES - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

INVALID_OUTBOUND_NAME - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

INVALID_OUTPUT_VALUES - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

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

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

invokeAddPartitions(ZkUtils, String, int, String, boolean) - Method in interface org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation

Invoke AdminUtils.addPartitions(kafka.utils.ZkUtils, java.lang.String, int, java.lang.String, boolean)

invokeAddPartitions(ZkUtils, String, int, String, boolean) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation

invokeAddPartitions(ZkUtils, String, int, String, boolean) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation

invokeCreateTopic(ZkUtils, String, int, int, Properties) - Method in interface org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation

Inovke AdminUtils.createTopic(kafka.utils.ZkUtils, java.lang.String, int, int, java.util.Properties)

invokeCreateTopic(ZkUtils, String, int, int, Properties) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation

invokeCreateTopic(ZkUtils, String, int, int, Properties) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation

isAutoAddPartitions() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

isAutoBindDlq() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

isAutoBindDlq() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

isAutoCommitOffset() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

isAutoCreateTopics() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

isAutoRebalanceEnabled() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

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

Deprecated.

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

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

isBatchingEnabled() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

isBindQueue() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

isCompress() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

isDeclareExchange() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

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

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

isDelayedExchange() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

isDurableSubscription() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

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

isEnableDlq() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

isExchangeAutoDelete() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

isExchangeDurable() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

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

isRepublishToDlq() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

isRequeueRejected() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

isResetOffsets() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

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

Deprecated.

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

isSync() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

isTransacted() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

isTransacted() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

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

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

JaasConfigurationProperties() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration.JaasConfigurationProperties

jaasInitializer() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration

JaasLoginModuleConfiguration - Class in org.springframework.cloud.stream.binder.kafka.config

Contains properties for setting up an AppConfigurationEntry that can be used for the Kafka or Zookeeper client.

JaasLoginModuleConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.JaasLoginModuleConfiguration

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

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

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

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

Message converter providing backwards compatibility for applications using an Java type as input.

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

K

Kafka09AdminUtilsOperation - Class in org.springframework.cloud.stream.binder.kafka.admin

Kafka09AdminUtilsOperation() - Constructor for class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation

kafka09AdminUtilsOperation() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration

Kafka10AdminUtilsOperation - Class in org.springframework.cloud.stream.binder.kafka.admin

Kafka10AdminUtilsOperation() - Constructor for class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation

kafka10AdminUtilsOperation() - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration

KafkaBinderConfiguration - Class in org.springframework.cloud.stream.binder.kafka.config

KafkaBinderConfiguration() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration

KafkaBinderConfiguration.JaasConfigurationProperties - Class in org.springframework.cloud.stream.binder.kafka.config

KafkaBinderConfigurationProperties - Class in org.springframework.cloud.stream.binder.kafka.config

KafkaBinderConfigurationProperties() - Constructor for class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

KafkaBinderHealthIndicator - Class in org.springframework.cloud.stream.binder.kafka

Health indicator for Kafka.

KafkaBinderHealthIndicator(KafkaMessageChannelBinder, ConsumerFactory<?, ?>) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaBinderHealthIndicator

KafkaBinderJaasInitializerListener - Class in org.springframework.cloud.stream.binder.kafka

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

KafkaBinderJaasInitializerListener.InternalConfiguration - Class in org.springframework.cloud.stream.binder.kafka

A Configuration set up programmatically by the Kafka binder

KafkaBindingProperties - Class in org.springframework.cloud.stream.binder.kafka

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

KafkaConsumerProperties - Class in org.springframework.cloud.stream.binder.kafka

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

KafkaConsumerProperties.StartOffset - Enum in org.springframework.cloud.stream.binder.kafka

KafkaExtendedBindingProperties - Class in org.springframework.cloud.stream.binder.kafka

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

KafkaMessageChannelBinder - Class in org.springframework.cloud.stream.binder.kafka

A Binder that uses Kafka as the underlying middleware.

KafkaMessageChannelBinder(KafkaBinderConfigurationProperties) - Constructor for class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

KafkaProducerProperties - Class in org.springframework.cloud.stream.binder.kafka

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

KafkaProducerProperties.CompressionType - Enum in org.springframework.cloud.stream.binder.kafka

KafkaTopicUtils - Class in org.springframework.cloud.stream.binder.kafka

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

lifecycle - Variable in class org.springframework.cloud.stream.binder.DefaultBinding

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

logger - Static variable in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration

M

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

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

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

A StreamListenerResultAdapter used for bridging an Output MessageChannel to a bound MessageChannel.

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

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

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

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

messageConverterConfigurer(BindingServiceProperties, CompositeMessageConverterFactory) - Method in class org.springframework.cloud.stream.config.BindingServiceConfiguration

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

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.BindingServiceConfiguration

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

name - Variable in class org.springframework.cloud.stream.binder.DefaultBinding

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

NAMESPACE_PROPERTY_NAME - Static variable in class org.springframework.cloud.stream.internal.InternalPropertyNames

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

A customized version of org.springframework.boot.actuate.metrics.integration.SpringIntegrationMetricReader that provides support for customizing channels with a namespace prefix.

NamespaceAwareSpringIntegrationMetricReader(String, IntegrationMBeanExporter) - Constructor for class org.springframework.cloud.stream.aggregate.NamespaceAwareSpringIntegrationMetricReader

NO_INPUT_DESTINATION - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

NoCloudConnectors() - Constructor for class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration.CloudProfile.NoCloudConnectors

NoCloudProfile() - Constructor for class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration.NoCloudProfile

O

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

A MessageConverter to convert a non-String objects to a String, when expected content type is "text/plain".

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

onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderJaasInitializerListener

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.

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

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

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.binder.kafka - package org.springframework.cloud.stream.binder.kafka

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

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

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

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

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

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

org.springframework.cloud.stream.internal - package org.springframework.cloud.stream.internal

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

org.springframework.cloud.stream.reflection - package org.springframework.cloud.stream.reflection

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

Indicates that an output binding target 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

outputAnnotationCount(Method) - Static method in class org.springframework.cloud.stream.binding.StreamListenerMethodUtils

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

Coordinates binding/unbinding of output binding targets 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.BindingServiceConfiguration

OverrideCloudConnectors() - Constructor for class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration.CloudProfile.CloudConnectors.OverrideCloudConnectors

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

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

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

Indicates the target partition of an outbound message.

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(EvaluationContext, ProducerProperties, PartitionKeyExtractorStrategy, PartitionSelectorStrategy) - 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.

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

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

partitionSize(String, ZkUtils) - Method in interface org.springframework.cloud.stream.binder.kafka.admin.AdminUtilsOperation

Find partition size from Kafka broker using AdminUtils

partitionSize(String, ZkUtils) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka09AdminUtilsOperation

partitionSize(String, ZkUtils) - Method in class org.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation

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.BindingServiceConfiguration.PostProcessorConfiguration

preSend(Message<?>, MessageChannel) - Method in class org.springframework.cloud.stream.binding.MessageConverterConfigurer.PartitioningInterceptor

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

Deprecated.

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.BindingServiceConfiguration.PostProcessorConfiguration

Adds property accessors for use in SpEL expression evaluation

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

put(String, T) - Method in class org.springframework.cloud.stream.config.EnvironmentEntryInitializingTreeMap

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

R

RabbitAdminException - Exception in org.springframework.cloud.stream.binder.rabbit

Exceptions thrown while interfacing with the RabbitMQ admin plugin.

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

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

RabbitBindingCleaner - Class in org.springframework.cloud.stream.binder.rabbit

Implementation of BindingCleaner for the RabbitBinder.

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

RabbitBindingProperties - Class in org.springframework.cloud.stream.binder.rabbit

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

RabbitCommonProperties - Class in org.springframework.cloud.stream.binder.rabbit

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

RabbitConsumerProperties - Class in org.springframework.cloud.stream.binder.rabbit

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

RabbitExtendedBindingProperties - Class in org.springframework.cloud.stream.binder.rabbit

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

RabbitManagementUtils - Class in org.springframework.cloud.stream.binder.rabbit

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

RabbitMessageChannelBinder - Class in org.springframework.cloud.stream.binder.rabbit

A Binder implementation backed by RabbitMQ.

RabbitMessageChannelBinder(ConnectionFactory, RabbitProperties) - Constructor for class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

RabbitMessageChannelBinderConfiguration - Class in org.springframework.cloud.stream.binder.rabbit.config

Configuration class for RabbitMQ message channel binder.

RabbitMessageChannelBinderConfiguration() - Constructor for class org.springframework.cloud.stream.binder.rabbit.config.RabbitMessageChannelBinderConfiguration

RabbitProducerProperties - Class in org.springframework.cloud.stream.binder.rabbit

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

RabbitServiceAutoConfiguration - Class in org.springframework.cloud.stream.binder.rabbit.config

Bind to services, either locally or in a cloud environment.

RabbitServiceAutoConfiguration() - Constructor for class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration

RabbitServiceAutoConfiguration.CloudProfile - Class in org.springframework.cloud.stream.binder.rabbit.config

Configuration to be used when the cloud profile is set.

RabbitServiceAutoConfiguration.CloudProfile.CloudConnectors - Class in org.springframework.cloud.stream.binder.rabbit.config

Configuration to be used when the cloud profile is set, and Cloud Connectors are found on the classpath.

RabbitServiceAutoConfiguration.CloudProfile.CloudConnectors.OverrideCloudConnectors - Class in org.springframework.cloud.stream.binder.rabbit.config

Configuration to be used if spring.cloud.stream.overrideCloudConnectors is set to true.

RabbitServiceAutoConfiguration.CloudProfile.CloudConnectors.UseCloudConnectors - Class in org.springframework.cloud.stream.binder.rabbit.config

Active only if spring.cloud.stream.overrideCloudConnectors is not set to true.

RabbitServiceAutoConfiguration.CloudProfile.NoCloudConnectors - Class in org.springframework.cloud.stream.binder.rabbit.config

RabbitServiceAutoConfiguration.NoCloudProfile - Class in org.springframework.cloud.stream.binder.rabbit.config

Configuration to be used when the cloud profile is not set.

register(String, Object) - Method in class org.springframework.cloud.stream.aggregate.SharedBindingTargetRegistry

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

Deprecated.

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

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

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

registerHandlerMethodOnListenedChannel(Method, StreamListener, Object) - Method in class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor

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

registerOutputBindingTargetBeanDefinition(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

RETURN_TYPE_MULTIPLE_OUTBOUND_SPECIFIED - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

RETURN_TYPE_NO_OUTBOUND_SPECIFIED - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

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

Deprecated.

in favor of StreamListener with reactive types

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

Deprecated.

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

Deprecated.

S

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

Determine the partition based on a key.

SELF_CONTAINED_APP_PROPERTY_NAME - Static variable in class org.springframework.cloud.stream.internal.InternalPropertyNames

SEND_TO_EMPTY_DESTINATION - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

SEND_TO_MULTIPLE_DESTINATIONS - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages

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

setAcknowledgeMode(AcknowledgeMode) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setAdminAddresses(String[]) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

setAdminUtilsOperation(AdminUtilsOperation) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

setApplicationContext(ApplicationContext) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

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.binder.kafka.KafkaBinderJaasInitializerListener

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.BindingServiceProperties

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

Deprecated.

setAutoAddPartitions(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setAutoBindDlq(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setAutoBindDlq(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setAutoCommitOffset(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

setAutoCommitOnError(Boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

setAutoCreateTopics(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setAutoRebalanceEnabled(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

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

setBatchBufferLimit(int) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setBatchingEnabled(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setBatchSize(int) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setBatchTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

setBatchTimeout(int) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

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.BindingServiceProperties

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

Deprecated.

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

setBindingRoutingKey(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

setBindings(Map<String, KafkaBindingProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties

setBindings(Map<String, RabbitBindingProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitExtendedBindingProperties

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

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

Deprecated.

setBindQueue(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

setBrokers(String...) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setBufferSize(int) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

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

setCompress(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setCompressingPostProcessor(MessagePostProcessor) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

Set a MessagePostProcessor to compress messages.

setCompressionType(KafkaProducerProperties.CompressionType) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

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

setConfiguration(Map<String, String>) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setConfiguration(Map<String, String>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

setConfiguration(Map<String, String>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

setConsumer(KafkaConsumerProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties

setConsumer(RabbitConsumerProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitBindingProperties

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

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

setControlFlag(String) - Method in class org.springframework.cloud.stream.binder.kafka.config.JaasLoginModuleConfiguration

setConversionService(ConversionService) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties

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

Deprecated.

setDeclareExchange(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

setDecompressingPostProcessor(MessagePostProcessor) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

Set a MessagePostProcessor to decompress messages.

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

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

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

Deprecated.

setDefaultBrokerPort(String) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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

setDefaultZkPort(String) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setDelayedExchange(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

setDelayExpression(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setDeliveryMode(MessageDeliveryMode) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

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

setDurableSubscription(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

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

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

Deprecated.

setEnableDlq(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

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

setEnvironment(Environment) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties

setExchangeAutoDelete(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

setExchangeDurable(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

setExchangeType(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitCommonProperties

setExtendedBindingProperties(KafkaExtendedBindingProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

setExtendedBindingProperties(RabbitExtendedBindingProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

setFetchSize(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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

setHeaders(String...) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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.BindingServiceProperties

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

Deprecated.

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

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

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

Deprecated.

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

setJaas(JaasLoginModuleConfiguration) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setLoginModule(String) - Method in class org.springframework.cloud.stream.binder.kafka.config.JaasLoginModuleConfiguration

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

setMaxConcurrency(int) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

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

setMaxWait(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setMetadataRetryOperations(RetryOperations) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

Retry configuration for operations such as validating topic creation

setMinPartitionCount(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setNodes(String[]) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

setOffsetUpdateCount(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setOffsetUpdateShutdownTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setOffsetUpdateTimeWindow(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setOptions(Map<String, String>) - Method in class org.springframework.cloud.stream.binder.kafka.config.JaasLoginModuleConfiguration

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

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

setPrefetch(int) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setPrefix(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setPrefix(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

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

setProducer(KafkaProducerProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBindingProperties

setProducer(RabbitProducerProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitBindingProperties

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

setProducerListener(ProducerListener<byte[], byte[]>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder

setQueueSize(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setRecoveryInterval(int) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

setRecoveryInterval(long) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

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

setReplicationFactor(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setReplyHeaderPatterns(String[]) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setReplyHeaderPatterns(String[]) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setRepublishToDlq(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setRequestHeaderPatterns(String[]) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setRequestHeaderPatterns(String[]) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setRequeueRejected(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setRequiredAcks(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

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

setResetOffsets(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

setRoutingKeyExpression(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setSocketBufferSize(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setStartOffset(KafkaConsumerProperties.StartOffset) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties

setSync(boolean) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties

setTransacted(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

setTransacted(boolean) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitProducerProperties

setTxSize(int) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitConsumerProperties

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

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

setZkConnectionTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setZkNodes(String...) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

setZkSessionTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfigurationProperties

sharedBindingTargetRegistry() - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.ParentConfiguration

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

Stores binding targets shared by the components of an aggregate application.

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

sharedChannelRegistry(SharedBindingTargetRegistry) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.ParentConfiguration

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

Deprecated.

in favour of SharedBindingTargetRegistry

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

Deprecated.

SingleBindingTargetBindable<T> - Class in org.springframework.cloud.stream.binding

A Bindable component that wraps a generic output binding target.

SingleBindingTargetBindable(String, T) - Constructor for class org.springframework.cloud.stream.binding.SingleBindingTargetBindable

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.

SPRING_CLOUD_STREAM_INTERNAL_PREFIX - Static variable in class org.springframework.cloud.stream.internal.InternalPropertyNames

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

Deprecated.

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

Deprecated.

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

Deprecated.

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 inputs declared via 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

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

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

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

This class contains utility methods for handling StreamListener annotated bean methods.

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

StreamListenerParameterAdapter<A,B> - Interface in org.springframework.cloud.stream.binding

Strategy for adapting a method argument type annotated with Input or Output from a binding type (e.g.

StreamListenerResultAdapter<R,B> - Interface in org.springframework.cloud.stream.binding

A strategy for adapting the result of a StreamListener annotated method to a binding target annotated with Output.

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

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

Deprecated.

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

Deprecated.

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

Deprecated.

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

An implementation of BindingTargetFactory for creating SubscribableChannels.

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

supports(Class<?>, Class<?>) - Method in class org.springframework.cloud.stream.binding.MessageChannelStreamListenerResultAdapter

supports(Class<?>, MethodParameter) - Method in interface org.springframework.cloud.stream.binding.StreamListenerParameterAdapter

Return true if the conversion from the binding target type to the argument type is supported.

supports(Class<?>, Class<?>) - Method in interface org.springframework.cloud.stream.binding.StreamListenerResultAdapter

Return true if the result type can be converted to the binding target.

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

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

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

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

T

target - Variable in class org.springframework.cloud.stream.binder.DefaultBinding

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

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

A MessageConverter to convert a Tuple to a JSON String

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

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.BindingService

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

Unbinds all the inputs associated with this instance.

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

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

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

Unbinds all the outputs associated with this instance.

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

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

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

unbindOutputs(BindingService) - Method in class org.springframework.cloud.stream.binding.SingleBindingTargetBindable

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

UseCloudConnectors() - Constructor for class org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration.CloudProfile.CloudConnectors.UseCloudConnectors

V

validateStreamListenerMessageHandler(Method) - Static method in class org.springframework.cloud.stream.binding.StreamListenerMethodUtils

validateStreamListenerMethod(Method, int, int, String, String, boolean) - Static method in class org.springframework.cloud.stream.binding.StreamListenerMethodUtils

validateTopicName(String) - Static method in class org.springframework.cloud.stream.binder.kafka.KafkaTopicUtils

Allowed chars are ASCII alphanumerics, '.', '_' and '-'.

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

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

valueOf(String) - Static method in enum org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties.StartOffset

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

valueOf(String) - Static method in enum org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties.CompressionType

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() - Static method in enum org.springframework.cloud.stream.binder.kafka.KafkaConsumerProperties.StartOffset

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

values() - Static method in enum org.springframework.cloud.stream.binder.kafka.KafkaProducerProperties.CompressionType

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

W

web(boolean) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

Flag to explicitly request a web or non-web environment.

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 W X