- Bindable - Interface in org.springframework.cloud.stream.binding
-
Marker interface for instances that can bind/unbind groups of inputs and outputs.
- 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.
- 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, BinderAwareChannelResolver.NewDestinationBindingCallback) - Constructor for class org.springframework.cloud.stream.binding.BinderAwareChannelResolver
-
- BinderAwareChannelResolver(BindingService, AbstractBindingTargetFactory<? extends MessageChannel>, DynamicDestinationsBindable, BinderAwareChannelResolver.NewDestinationBindingCallback, GlobalChannelInterceptorProcessor) - Constructor for class org.springframework.cloud.stream.binding.BinderAwareChannelResolver
-
- binderAwareChannelResolver(BindingService, AbstractBindingTargetFactory<? extends MessageChannel>, DynamicDestinationsBindable, BinderAwareChannelResolver.NewDestinationBindingCallback, GlobalChannelInterceptorProcessor) - Method in class org.springframework.cloud.stream.config.BindingServiceConfiguration
-
- BinderAwareChannelResolver.NewDestinationBindingCallback<T> - Interface in org.springframework.cloud.stream.binding
-
Configure a new destination before it is bound.
- BinderAwareRouterBeanPostProcessor - Class in org.springframework.cloud.stream.binding
-
- BinderAwareRouterBeanPostProcessor(AbstractMappingMessageRouter[], DestinationResolver<MessageChannel>) - Constructor for class org.springframework.cloud.stream.binding.BinderAwareRouterBeanPostProcessor
-
Deprecated.
- binderAwareRouterBeanPostProcessor(AbstractMappingMessageRouter[], DestinationResolver<MessageChannel>) - Method in class org.springframework.cloud.stream.config.BindingServiceConfiguration
-
- BinderConfiguration - Class in org.springframework.cloud.stream.binder
-
- BinderConfiguration(String, Map<String, Object>, 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
-
- BinderHeaderMapper - Class in org.springframework.cloud.stream.binder.kafka
-
Deprecated.
- BinderHeaderMapper() - Constructor for class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper
-
Deprecated.
Construct an instance with the default object mapper and default header patterns
for outbound headers; all inbound headers are mapped.
- BinderHeaderMapper(ObjectMapper) - Constructor for class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper
-
Deprecated.
Construct an instance with the provided object mapper and default header patterns
for outbound headers; all inbound headers are mapped.
- BinderHeaderMapper(String...) - Constructor for class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper
-
Deprecated.
Construct an instance with a default object mapper and the provided header patterns
for outbound headers; all inbound headers are mapped.
- BinderHeaderMapper(ObjectMapper, String...) - Constructor for class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper
-
Deprecated.
Construct an instance with the provided object mapper and the provided header
patterns for outbound headers; all inbound headers are mapped.
- BinderHeaderMapper.NonTrustedHeaderType - Class in org.springframework.cloud.stream.binder.kafka
-
Deprecated.
Represents a header that could not be decoded due to an untrusted type.
- 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.RabbitHealthIndicatorConfiguration
-
- 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.BindersHealthIndicatorAutoConfiguration
-
- BindersHealthIndicatorAutoConfiguration - Class in org.springframework.cloud.stream.config
-
- BindersHealthIndicatorAutoConfiguration() - Constructor for class org.springframework.cloud.stream.config.BindersHealthIndicatorAutoConfiguration
-
- bindersHealthIndicatorListener(CompositeHealthIndicator) - Method in class org.springframework.cloud.stream.config.BindersHealthIndicatorAutoConfiguration
-
- 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
-
- 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.
- BindingCreatedEvent - Class in org.springframework.cloud.stream.binder
-
ApplicationEvent fired whenever the the Binding is created.
- BindingCreatedEvent(Binding<?>) - Constructor for class org.springframework.cloud.stream.binder.BindingCreatedEvent
-
- 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
-
- bindingsEndpoint(List<InputBindingLifecycle>) - Method in class org.springframework.cloud.stream.config.BindingsEndpointAutoConfiguration
-
- BindingsEndpoint - Class in org.springframework.cloud.stream.endpoint
-
Actuator endpoint for binding control
- BindingsEndpoint(List<InputBindingLifecycle>) - Constructor for class org.springframework.cloud.stream.endpoint.BindingsEndpoint
-
- BindingsEndpointAutoConfiguration - Class in org.springframework.cloud.stream.config
-
- BindingsEndpointAutoConfiguration() - Constructor for class org.springframework.cloud.stream.config.BindingsEndpointAutoConfiguration
-
- 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, TaskScheduler) - Constructor for class org.springframework.cloud.stream.binding.BindingService
-
- bindingService(BindingServiceProperties, BinderFactory, TaskScheduler) - 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
-
- 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
-
- 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.BindableProxyFactory
-
- bindOutputs(BindingService) - Method in class org.springframework.cloud.stream.binding.SingleBindingTargetBindable
-
- bindPollableConsumer(String, String, PollableSource<MessageHandler>, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- bindPollableConsumer(String, String, PollableSource<H>, C) - Method in interface org.springframework.cloud.stream.binder.PollableConsumerBinder
-
Configure a binding for a pollable message source.
- 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
-
- bindTo(MeterRegistry) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics
-
- build() - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer
-
- buildPartitionRoutingExpression(String) - Method in class org.springframework.cloud.stream.binder.AbstractBinder
-
Deprecated.
- buildRetryTemplate(ConsumerProperties) - Method in class org.springframework.cloud.stream.binder.AbstractBinder
-
Create and configure a default retry template unless one
has already been provided via @Bean by an application.
- canConvertFrom(Message<?>, Class<?>) - Method in class org.springframework.cloud.stream.converter.KryoMessageConverter
-
Deprecated.
- canConvertFrom(Message<?>, Class<?>) - Method in class org.springframework.cloud.stream.converter.ObjectStringMessageConverter
-
- 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.
- changeState(String, BindingsEndpoint.State) - Method in class org.springframework.cloud.stream.endpoint.BindingsEndpoint
-
- 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
-
- channelFactory(CompositeMessageChannelConfigurer) - Method in class org.springframework.cloud.stream.config.BindingServiceConfiguration
-
- channels() - Method in class org.springframework.cloud.stream.endpoint.ChannelsEndpoint
-
- channelsEndpoint(BindingServiceProperties) - Method in class org.springframework.cloud.stream.config.ChannelsEndpointAutoConfiguration
-
- 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
-
- ChannelsEndpointAutoConfiguration - Class in org.springframework.cloud.stream.config
-
- ChannelsEndpointAutoConfiguration() - Constructor for class org.springframework.cloud.stream.config.ChannelsEndpointAutoConfiguration
-
- ChannelsMetaData() - Constructor for class org.springframework.cloud.stream.endpoint.ChannelsEndpoint.ChannelsMetaData
-
- checkCompatiblePollableBinder(Binder, Class<?>) - Static method in class org.springframework.cloud.stream.reflection.GenericsUtils
-
Return the generic type of PollableSource to determine if it is appropriate
for the binder.
- clean(String, boolean) - Method in interface org.springframework.cloud.stream.binder.BindingCleaner
-
Clean up all resources for the supplied stream/job.
- clear() - Method in class org.springframework.cloud.stream.binder.MessageValues
-
- close(RetryContext, RetryCallback<T, E>, Throwable) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- 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
-
- CompositeMessageChannelConfigurer - Class in org.springframework.cloud.stream.binding
-
- 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.ContentTypeConfiguration
-
- 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
-
- CONDITION_ON_DECLARATIVE_METHOD - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages
-
- CONDITION_ON_METHOD_RETURNING_VALUE - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages
-
- configurableCompositeMessageConverter(CompositeMessageConverterFactory) - Method in class org.springframework.cloud.stream.config.ContentTypeConfiguration
-
- configure(String, MessageChannel, ProducerProperties, T) - Method in interface org.springframework.cloud.stream.binding.BinderAwareChannelResolver.NewDestinationBindingCallback
-
Configure the properties or channel before binding.
- 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
-
- configureKryoInstance(Kryo) - Method in class org.springframework.cloud.stream.converter.KryoMessageConverter
-
Deprecated.
- 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
-
- configurePolledMessageSource(PollableMessageSource, String) - Method in class org.springframework.cloud.stream.binding.CompositeMessageChannelConfigurer
-
- configurePolledMessageSource(PollableMessageSource, String) - Method in interface org.springframework.cloud.stream.binding.MessageChannelAndSourceConfigurer
-
Configure the provided message source binding.
- configurePolledMessageSource(PollableMessageSource, String) - Method in class org.springframework.cloud.stream.binding.MessageConverterConfigurer
-
- connectionNamer(CachingConnectionFactory) - Method in class org.springframework.cloud.stream.binder.rabbit.config.RabbitMessageChannelBinderConfiguration
-
- 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.
- ConsumerDestination - Interface in org.springframework.cloud.stream.provisioning
-
- 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
-
- ContentTypeConfiguration - Class in org.springframework.cloud.stream.config
-
- ContentTypeConfiguration() - Constructor for class org.springframework.cloud.stream.config.ContentTypeConfiguration
-
- 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
-
Deprecated.
- convertFromInternal(Message<?>, Class<?>, Object) - Method in class org.springframework.cloud.stream.converter.JsonUnmarshallingConverter
-
Deprecated.
- 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
-
Deprecated.
- convertToInternal(Object, MessageHeaders, Object) - Method in class org.springframework.cloud.stream.converter.JavaSerializationMessageConverter
-
Deprecated.
- convertToInternal(Object, MessageHeaders, Object) - Method in class org.springframework.cloud.stream.converter.JsonUnmarshallingConverter
-
Deprecated.
- 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
-
Deprecated.
- copyHeadersIfAbsent(Map<String, Object>) - Method in class org.springframework.cloud.stream.binder.MessageValues
-
- copyProperties(Object, Object) - Method in interface org.springframework.cloud.stream.config.MergableProperties
-
- createAndBindInputs(BindingService) - Method in interface org.springframework.cloud.stream.binding.Bindable
-
Binds all the inputs associated with this instance.
- createAndBindInputs(BindingService) - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory
-
- createConsumerEndpoint(ConsumerDestination, String, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
Creates MessageProducer
that receives data from the consumer destination.
- createConsumerEndpoint(ConsumerDestination, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- createConsumerEndpoint(ConsumerDestination, String, 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.MessageSourceBindingTargetFactory
-
- createInput(String) - Method in class org.springframework.cloud.stream.binding.SubscribableChannelBindingTargetFactory
-
- createKafkaConsumerFactory(boolean, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- 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.MessageSourceBindingTargetFactory
-
- createOutput(String) - Method in class org.springframework.cloud.stream.binding.SubscribableChannelBindingTargetFactory
-
- createPolledConsumerResources(String, String, ConsumerDestination, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- createPolledConsumerResources(String, String, ConsumerDestination, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- createPolledConsumerResources(String, String, ConsumerDestination, ExtendedConsumerProperties<RabbitConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- createProducerMessageHandler(ProducerDestination, P, MessageChannel) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
Creates a MessageHandler
with the ability to send data to the target
middleware.
- createProducerMessageHandler(ProducerDestination, ExtendedProducerProperties<KafkaProducerProperties>, MessageChannel) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- createProducerMessageHandler(ProducerDestination, ExtendedProducerProperties<RabbitProducerProperties>, MessageChannel) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- CustomMimeTypeConverter - Class in org.springframework.cloud.stream.converter
-
A custom converter for MimeType
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
-
- GenericsUtils - Class in org.springframework.cloud.stream.reflection
-
Internal utilities for handling generics.
- 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
-
- 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
-
- getApplicationContext() - Method in class org.springframework.cloud.stream.binder.AbstractBinder
-
- getApplicationEventPublisher() - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- getArgs() - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer
-
- getBackOffInitialInterval() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- getBackOffMaxInterval() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- getBackOffMultiplier() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- getBeanFactory() - Method in class org.springframework.cloud.stream.binder.AbstractBinder
-
- getBinder(String, 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(String, Class<T>) - Method in class org.springframework.cloud.stream.binding.BindingService
-
- getBinder() - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- getBinder(String) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getBinders() - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- 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
-
- getBindingProperties(String) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getBindingRetryInterval() - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getBindings() - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getBindingServiceProperties() - Method in class org.springframework.cloud.stream.binding.BindingService
-
- getBindingTargetName(Annotation, Method) - Static method in class org.springframework.cloud.stream.binding.BindingBeanDefinitionRegistryUtils
-
- getChannelBindingServiceProperties() - Method in class org.springframework.cloud.stream.binding.BindingService
-
Deprecated.
- getConcurrency() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- getConfigurationClasses() - Method in class org.springframework.cloud.stream.binder.BinderType
-
- getConsumer() - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- getConsumerProperties(String) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getContentType() - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- getDefaultBinder() - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getDefaultContentType(Object) - Method in class org.springframework.cloud.stream.converter.KryoMessageConverter
-
Deprecated.
- getDefaultErrorMessageHandler(LastSubscriberAwareChannel, boolean) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
Return the default error message handler, which throws the error message payload to
the caller if there are no user handlers subscribed.
- getDefaultName() - Method in class org.springframework.cloud.stream.binder.BinderType
-
- getDestination() - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- getDynamicDestinations() - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getEnvironment() - Method in class org.springframework.cloud.stream.config.BinderProperties
-
- getErrorBridgeName(ConsumerDestination, String, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- getErrorBridgeName(ProducerDestination) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- getErrorChannel() - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.ErrorInfrastructure
-
- getErrorMessageHandler(ConsumerDestination, String, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
Binders can return a message handler to be subscribed to the error channel.
- getErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- getErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties<RabbitConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- getErrorMessageHandlerName(ConsumerDestination, String, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- getErrorMessageStrategy() - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
Binders can return an ErrorMessageStrategy
for building error messages; binder
implementations typically might add extra headers to the error message.
- getErrorMessageStrategy() - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- getErrorMessageStrategy() - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- getErrorRecovererName(ConsumerDestination, String, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- getEvaluationContext() - Method in class org.springframework.cloud.stream.binder.AbstractBinder
-
- getExportProperties() - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- getExtendedConsumerProperties(String) - Method in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties
-
- getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- getExtendedInfo() - Method in interface org.springframework.cloud.stream.binder.Binding
-
- getExtendedProducerProperties(String) - Method in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties
-
- getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- getExtendedProducerProperties(Object, String) - Method in class org.springframework.cloud.stream.binding.BindingService
-
- getExtension() - Method in class org.springframework.cloud.stream.binder.ExtendedConsumerProperties
-
- getExtension() - Method in class org.springframework.cloud.stream.binder.ExtendedProducerProperties
-
- getFixedDelay() - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties
-
- getGroup() - Method in class org.springframework.cloud.stream.binder.DefaultBinding
-
- getGroup() - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- getGroup(String) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getHandler() - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.ErrorInfrastructure
-
- 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.MessageValues
-
- getHeaderValue() - Method in class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper.NonTrustedHeaderType
-
Deprecated.
- 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.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
-
- getInstanceIndex() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- getInstanceIndex() - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getJavaTypeForJavaObjectContentType(MimeType) - Static method in class org.springframework.cloud.stream.converter.MessageConverterUtils
-
Get the java Object type for the MimeType X_JAVA_OBJECT
- getKey() - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- getMaxAttempts() - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- getMaxMessagesPerPoll() - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties
-
- getMessageConverterForAllRegistered() - Method in class org.springframework.cloud.stream.converter.CompositeMessageConverterFactory
-
- getMessageConverterForType(MimeType) - Method in class org.springframework.cloud.stream.converter.CompositeMessageConverterFactory
-
Creation method.
- getMessageHandlerNotPropagatedHeaders() - Method in class org.springframework.cloud.stream.config.SpringIntegrationProperties
-
- getMeterFilter() - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- getMimeType(MessageHeaders) - Method in class org.springframework.cloud.stream.converter.KryoMessageConverter
-
Deprecated.
- getMimeType(String) - Static method in class org.springframework.cloud.stream.converter.MessageConverterUtils
-
- getName() - Method in interface org.springframework.cloud.stream.binder.Binding
-
Returns the name of this binding (i.e., channel name)
- getName() - Method in class org.springframework.cloud.stream.binder.DefaultBinding
-
- getName() - Method in interface org.springframework.cloud.stream.provisioning.ConsumerDestination
-
Provides the destination name.
- getName() - Method in interface org.springframework.cloud.stream.provisioning.ProducerDestination
-
Provides the destination name.
- getNameForPartition(int) - Method in interface org.springframework.cloud.stream.provisioning.ProducerDestination
-
Provides the destination name for a given partition.
- getNamespace() - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.AppConfigurer
-
- getObject() - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory
-
- getObjectMapper() - Method in class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper
-
Deprecated.
Return the object mapper.
- getObjectType() - Method in class org.springframework.cloud.stream.binding.BindableProxyFactory
-
- getOutboundBindingTargetName(Method) - Static method in class org.springframework.cloud.stream.binding.StreamAnnotationCommonMethodUtils
-
- 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.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 parameterized type, return 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
-
Deprecated.
- getPartitionKeyExtractorName() - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- getPartitionSelectorClass() - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
Deprecated.
- getPartitionSelectorExpression() - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- getPartitionSelectorName() - 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.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.
- getPolledConsumerErrorMessageHandler(ConsumerDestination, String, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
Binders can return a message handler to be subscribed to the error channel.
- getPolledConsumerErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties<KafkaConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- getPolledConsumerErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties<RabbitConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- getPolledConsumerRecoveryCallback(AbstractMessageChannelBinder.ErrorInfrastructure, C) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
Implementations can override the default ErrorMessageSendingRecoverer
.
- getPollerMetadata() - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties
-
- getProducer() - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- getProducerFactory(String, ExtendedProducerProperties<KafkaProducerProperties>) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- getProducerProperties(String) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- getProperties() - Method in class org.springframework.cloud.stream.binder.BinderConfiguration
-
- getProperties() - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- getRecoverer() - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.ErrorInfrastructure
-
- getRequiredGroups() - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- getScheduleInterval() - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- getState() - Method in class org.springframework.cloud.stream.binder.DefaultBinding
-
- getSupportedMimeTypes() - Method in class org.springframework.cloud.stream.converter.KryoMessageConverter
-
Deprecated.
- getToStringClasses() - Method in class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper
-
Deprecated.
Provide direct access to the toString() classes by subclasses.
- getTrustedPackages() - Method in class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper
-
Deprecated.
Provide direct access to the trusted packages set for subclasses.
- getType() - Method in class org.springframework.cloud.stream.config.BinderProperties
-
- getUntrustedType() - Method in class org.springframework.cloud.stream.binder.kafka.BinderHeaderMapper.NonTrustedHeaderType
-
Deprecated.
- 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.
- parent(Object, String...) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder
-
- parent(Object[], String[]) - Method in class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder
-
- ParentActuatorConfiguration() - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.ParentActuatorConfiguration
-
- ParentConfiguration() - Constructor for class org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder.ParentConfiguration
-
- PARSER - Static variable in class org.springframework.cloud.stream.binder.rabbit.RabbitExpressionEvaluatingInterceptor
-
- PARTITION_HEADER - Static variable in class org.springframework.cloud.stream.binder.BinderHeaders
-
Indicates the target partition of an outbound message.
- PARTITION_OVERRIDE - 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.
- pause() - Method in interface org.springframework.cloud.stream.binder.Binding
-
Pauses the target component represented by this instance if and only if the component
implements Pausable
interface
NOTE: At the time the instance is created the component is already started and active.
- pause() - Method in class org.springframework.cloud.stream.binder.DefaultBinding
-
- poll(MessageHandler) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- poll(MessageHandler, ParameterizedTypeReference<?>) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- poll(H) - Method in interface org.springframework.cloud.stream.binder.PollableSource
-
Poll the consumer.
- poll(H, ParameterizedTypeReference<?>) - Method in interface org.springframework.cloud.stream.binder.PollableSource
-
Poll the consumer and convert the payload to the type.
- PollableConsumerBinder<H,C extends ConsumerProperties> - Interface in org.springframework.cloud.stream.binder
-
A binder that supports pollable message sources.
- PollableMessageSource - Interface in org.springframework.cloud.stream.binder
-
- PollableSource<H> - Interface in org.springframework.cloud.stream.binder
-
A mechanism to poll a consumer.
- PolledConsumerResources(MessageSource<?>, AbstractMessageChannelBinder.ErrorInfrastructure) - Constructor for class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.PolledConsumerResources
-
- pool - Variable in class org.springframework.cloud.stream.converter.KryoMessageConverter
-
Deprecated.
- postProcessAfterInitialization(Object, String) - Method in class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor
-
- postProcessAnnotation(StreamListener, Method) - Method in class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor
-
Extension point, allowing subclasses to customize the
StreamListener
annotation detected by the postprocessor.
- postProcessEnvironment(ConfigurableEnvironment, SpringApplication) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
-
- postProcessOutputChannel(MessageChannel, P) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
Allows subclasses to perform post processing on the channel - for example to
add more interceptors.
- postProcessOutputChannel(MessageChannel, ExtendedProducerProperties<RabbitProducerProperties>) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- postProcessPollableSource(DefaultPollableMessageSource) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- postProcessPollableSource(DefaultPollableMessageSource) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- postProcessPollableSource(DefaultPollableMessageSource) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- PREFIX - Static variable in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- preSend(Message<?>, MessageChannel) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitExpressionEvaluatingInterceptor
-
- preSend(Message<?>, MessageChannel) - Method in class org.springframework.cloud.stream.binding.MessageConverterConfigurer.PartitioningInterceptor
-
- 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
-
- ProducerDestination - Interface in org.springframework.cloud.stream.provisioning
-
- 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
-
- provisionConsumerDestination(String, String, C) - Method in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider
-
Creates the middleware destination on the physical broker for the consumer to
consume data.
- ProvisioningException - Exception in org.springframework.cloud.stream.provisioning
-
Generic unchecked exception to wrap middleware or technology specific exceptions.
- ProvisioningException(String) - Constructor for exception org.springframework.cloud.stream.provisioning.ProvisioningException
-
Constructor that takes a message.
- ProvisioningException(String, Throwable) - Constructor for exception org.springframework.cloud.stream.provisioning.ProvisioningException
-
Constructor that takes a message and a root cause.
- provisioningProvider - Variable in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- ProvisioningProvider<C extends ConsumerProperties,P extends ProducerProperties> - Interface in org.springframework.cloud.stream.provisioning
-
Provisioning SPI that allows the users to provision destinations such as queues and
topics.
- provisionProducerDestination(String, P) - Method in interface org.springframework.cloud.stream.provisioning.ProvisioningProvider
-
Creates middleware destination on the physical broker for the producer to send
data.
- 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
-
- SCST_VERSION - Static variable in class org.springframework.cloud.stream.binder.BinderHeaders
-
Indicates the Spring Cloud Stream version.
- 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.StreamAnnotationErrorMessages
-
- 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.StreamAnnotationErrorMessages
-
- SEND_TO_MULTIPLE_DESTINATIONS - Static variable in class org.springframework.cloud.stream.binding.StreamListenerErrorMessages
-
- serialize(Object) - Method in class org.springframework.cloud.stream.converter.KryoMessageConverter
-
Deprecated.
- serializePayloadIfNecessary(Message<?>) - Method in class org.springframework.cloud.stream.binder.AbstractBinder
-
Deprecated.
- setAdminAddresses(String[]) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- 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.binding.ContextStartAfterRefreshListener
-
- 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.micrometer.ApplicationMetricsProperties
-
- setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder
-
- setAttributesProvider(BiConsumer<AttributeAccessor, Message<?>>) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- setBackOffInitialInterval(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- setBackOffMaxInterval(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- setBackOffMultiplier(double) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- setBeanFactory(BeanFactory) - Method in class org.springframework.cloud.stream.binding.BinderAwareChannelResolver
-
- setBeanFactory(BeanFactory) - Method in class org.springframework.cloud.stream.binding.MessageConverterConfigurer
-
- setBinder(String) - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- setBinders(Map<String, BinderProperties>) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- setBindingRetryInterval(int) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- setBindings(Map<String, BindingProperties>) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- setCompressingPostProcessor(MessagePostProcessor) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
Set a MessagePostProcessor
to compress messages.
- setConcurrency(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- setConsumer(ConsumerProperties) - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- setContentType(String) - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- setConversionService(ConversionService) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- 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
-
- setDefaultCandidate(boolean) - Method in class org.springframework.cloud.stream.config.BinderProperties
-
- setDestination(String) - Method in class org.springframework.cloud.stream.config.BindingProperties
-
- setDynamicDestinations(String[]) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- setEnvironment(Properties) - Method in class org.springframework.cloud.stream.config.BinderProperties
-
- setEnvironment(Map<String, Object>) - Method in class org.springframework.cloud.stream.config.BinderProperties
-
- setEnvironment(Environment) - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- setErrorChannel(MessageChannel) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- setErrorChannelEnabled(boolean) - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- setErrorMessageStrategy(ErrorMessageStrategy) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- setExtendedBindingProperties(KafkaExtendedBindingProperties) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder
-
- setExtendedBindingProperties(RabbitExtendedBindingProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- 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
-
- 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
-
- setInstanceIndex(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- setInstanceIndex(int) - Method in class org.springframework.cloud.stream.config.BindingServiceProperties
-
- setKey(String) - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- setListeners(Collection<DefaultBinderFactory.Listener>) - Method in class org.springframework.cloud.stream.binder.DefaultBinderFactory
-
- setMaxAttempts(int) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- setMaxMessagesPerPoll(long) - Method in class org.springframework.cloud.stream.config.DefaultPollerProperties
-
- setMessageHandlerNotPropagatedHeaders(String[]) - Method in class org.springframework.cloud.stream.config.SpringIntegrationProperties
-
- setMeterFilter(String) - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- setNodes(String[]) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder
-
- 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
-
Deprecated.
- setPartitionKeyExtractorName(String) - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- setPartitionSelectorClass(Class<?>) - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
Deprecated.
- setPartitionSelectorExpression(Expression) - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- setPartitionSelectorName(String) - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- setPayload(Object) - Method in class org.springframework.cloud.stream.binder.MessageValues
-
Set the payload
- setPrettyPrint(boolean) - Method in class org.springframework.cloud.stream.converter.TupleJsonMessageConverter
-
Deprecated.
- 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
-
- setProperties(String[]) - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- setRecoveryCallback(RecoveryCallback<Object>) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- setRequiredGroups(String...) - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- setRetryTemplate(RetryTemplate) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- setScheduleInterval(Duration) - Method in class org.springframework.cloud.stream.micrometer.ApplicationMetricsProperties
-
- setSource(MessageSource<?>) - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- setTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderHealthIndicator
-
Set the timeout in seconds to retrieve health information.
- setTimeout(int) - Method in class org.springframework.cloud.stream.binder.kafka.KafkaBinderMetrics
-
- setType(String) - Method in class org.springframework.cloud.stream.config.BinderProperties
-
- setUseNativeDecoding(boolean) - Method in class org.springframework.cloud.stream.binder.ConsumerProperties
-
- setUseNativeEncoding(boolean) - Method in class org.springframework.cloud.stream.binder.ProducerProperties
-
- 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 - Class in org.springframework.cloud.stream.aggregate
-
- SharedChannelRegistry(SharedBindingTargetRegistry) - Constructor for class org.springframework.cloud.stream.aggregate.SharedChannelRegistry
-
Deprecated.
- shouldCopyRequestHeaders() - Method in class org.springframework.cloud.stream.binding.StreamListenerMessageHandler
-
- 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.
- spelPropertyAccessorRegistrar() - Static method in class org.springframework.cloud.stream.config.SpelExpressionConverterConfiguration
-
Provide a SpelPropertyAccessorRegistrar
supplied
with the JsonPropertyAccessor
and TuplePropertyAccessor
.
- SPRING_CLOUD_STREAM_INTERNAL_PREFIX - Static variable in class org.springframework.cloud.stream.internal.InternalPropertyNames
-
- SPRING_KAFKA - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
-
- SPRING_KAFKA_CONSUMER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
-
- SPRING_KAFKA_CONSUMER_KEY_DESERIALIZER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
-
- SPRING_KAFKA_CONSUMER_VALUE_DESERIALIZER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
-
- SPRING_KAFKA_PRODUCER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
-
- SPRING_KAFKA_PRODUCER_KEY_SERIALIZER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
-
- SPRING_KAFKA_PRODUCER_VALUE_SERIALIZER - Static variable in class org.springframework.cloud.stream.binder.kafka.KafkaBinderEnvironmentPostProcessor
-
- SpringIntegrationProperties - Class in org.springframework.cloud.stream.config
-
Contains properties for Spring Integration settings.
- SpringIntegrationProperties() - Constructor for class org.springframework.cloud.stream.config.SpringIntegrationProperties
-
- 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 interface org.springframework.cloud.stream.binder.Binding
-
Stops the target component represented by this instance.
- start() - Method in class org.springframework.cloud.stream.binder.DefaultBinding
-
- start() - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- stop() - Method in interface org.springframework.cloud.stream.binder.Binding
-
Starts the target component represented by this instance.
- stop() - Method in class org.springframework.cloud.stream.binder.DefaultBinding
-
- stop() - Method in class org.springframework.cloud.stream.binder.DefaultPollableMessageSource
-
- STREAM_LISTENER_ANNOTATION_BEAN_POST_PROCESSOR_NAME - Static variable in class org.springframework.cloud.stream.config.BindingServiceConfiguration
-
- StreamAnnotationCommonMethodUtils - Class in org.springframework.cloud.stream.binding
-
Common methods that can be used across various Stream annotations.
- StreamAnnotationCommonMethodUtils() - Constructor for class org.springframework.cloud.stream.binding.StreamAnnotationCommonMethodUtils
-
- StreamAnnotationErrorMessages - Class in org.springframework.cloud.stream.binding
-
- StreamAnnotationErrorMessages() - Constructor for class org.springframework.cloud.stream.binding.StreamAnnotationErrorMessages
-
- 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() - Constructor for class org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor
-
- streamListenerAnnotationBeanPostProcessor() - Static method in class org.springframework.cloud.stream.config.BindingServiceConfiguration
-
- StreamListenerErrorMessages - Class in org.springframework.cloud.stream.binding
-
- StreamListenerErrorMessages() - Constructor for class org.springframework.cloud.stream.binding.StreamListenerErrorMessages
-
- StreamListenerMessageHandler - Class in org.springframework.cloud.stream.binding
-
- 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
.
- StreamListenerSetupMethodOrchestrator - Interface in org.springframework.cloud.stream.binding
-
- StreamMessageConverter - Annotation Type in org.springframework.cloud.stream.annotation
-
- StreamRetryTemplate - Annotation Type in org.springframework.cloud.stream.annotation
-
Marker to tag an instance of RetryTemplate
to be used by the binder.
- SubscribableChannelBindingTargetFactory - Class in org.springframework.cloud.stream.binding
-
- 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(Method) - Method in interface org.springframework.cloud.stream.binding.StreamListenerSetupMethodOrchestrator
-
Checks the method annotated with
StreamListener
to see if this implementation
can successfully orchestrate this method.
- supports(Class<?>) - Method in class org.springframework.cloud.stream.converter.JavaSerializationMessageConverter
-
Deprecated.
- supports(Class<?>) - Method in class org.springframework.cloud.stream.converter.JsonUnmarshallingConverter
-
Deprecated.
- supports(Class<?>) - Method in class org.springframework.cloud.stream.converter.ObjectStringMessageConverter
-
- supports(Class<?>) - Method in class org.springframework.cloud.stream.converter.TupleJsonMessageConverter
-
Deprecated.
- supportsMimeType(MessageHeaders) - Method in class org.springframework.cloud.stream.converter.KryoMessageConverter
-
Deprecated.
- supportsMimeType(MessageHeaders) - Method in class org.springframework.cloud.stream.converter.ObjectStringMessageConverter
-