Index

A B C D E G L M N O P R S U
All Classes and Interfaces|All Packages|Constant Field Values

A

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

afterUnbindProducer(ProducerDestination, ExtendedProducerProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

B

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

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

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

Construct an instance with the provided exception message supplier.

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

binderName() - Method in class org.springframework.cloud.stream.binder.rabbit.config.RabbitBinderConfiguration

C

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

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

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

configureAdapter(AmqpInboundChannelAdapter) - Static method in class org.springframework.cloud.stream.binder.rabbit.StreamUtils

Configure the channel adapter for streams support.

createConsumerEndpoint(ConsumerDestination, String, ExtendedConsumerProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

createContainer(ConsumerDestination, String, ExtendedConsumerProperties, String, ApplicationContext) - Static method in class org.springframework.cloud.stream.binder.rabbit.StreamUtils

Create a StreamListenerContainer.

createPolledConsumerResources(String, String, ConsumerDestination, ExtendedConsumerProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

createProducerMessageHandler(ProducerDestination, ExtendedProducerProperties, MessageChannel) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

createStreamMessageHandler(ProducerDestination, ExtendedProducerProperties, MessageChannel, String, RabbitProducerProperties, AbstractApplicationContext, Function) - Static method in class org.springframework.cloud.stream.binder.rabbit.StreamUtils

Create a RabbitStreamMessageHandler.

D

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

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

DELAY_HEADER - Static variable in class org.springframework.cloud.stream.binder.rabbit.RabbitExpressionEvaluatingInterceptor

Default name for delay header.

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

E

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

Configuration for extended binding metadata.

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

G

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

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

Get the underlying ConnectionFactory instance to allow manually altering the connection lifecycle.

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

getErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

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

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

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

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

getPolledConsumerErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

L

logger - Variable in class org.springframework.cloud.stream.binder.rabbit.BatchCapableRejectAndDontRequeueRecoverer

M

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

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

N

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

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

O

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

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

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

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

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

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

P

PARSER - Static variable in class org.springframework.cloud.stream.binder.rabbit.RabbitExpressionEvaluatingInterceptor

Instance of ExpressionParser.

postProcessBatchMessageOnFailure(Message, int) - Method in class org.springframework.cloud.stream.binder.rabbit.config.DefaultMessageConverterHelper

postProcessOutputChannel(MessageChannel, ExtendedProducerProperties) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitMessageChannelBinder

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

preSend(Message, MessageChannel) - Method in class org.springframework.cloud.stream.binder.rabbit.RabbitExpressionEvaluatingInterceptor

R

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

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

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

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

Configuration to be used when the cloud profile is set.

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

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

Configuration to be used if spring.cloud.stream.override-cloud-connectors is set to true.

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

Active only if spring.cloud.stream.override-cloud-connectors is not set to true.

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

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

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

RabbitBinderConfiguration.RabbitHealthIndicatorConfiguration - Class in org.springframework.cloud.stream.binder.rabbit.config

Configuration for Rabbit health indicator.

RabbitBinderRuntimeHints - Class in org.springframework.cloud.stream.binder.rabbit.aot

RuntimeHintsRegistrar for the Rabbit binder in Spring Cloud Stream.

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

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

Configuration for RabbitTemplate and CachingConnectionFactory.

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

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

Interceptor to evaluate expressions for outbound messages before serialization.

RabbitExpressionEvaluatingInterceptor(Expression, Expression, EvaluationContext) - Constructor for class org.springframework.cloud.stream.binder.rabbit.RabbitExpressionEvaluatingInterceptor

Construct an instance with the provided expressions and evaluation context.

rabbitExtendedPropertiesDefaultMappingsProvider() - Method in class org.springframework.cloud.stream.binder.rabbit.config.ExtendedBindingHandlerMappingsProviderConfiguration

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

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

A Binder implementation backed by RabbitMQ.

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

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

RabbitMessageChannelBinder(ConnectionFactory, RabbitProperties, RabbitExchangeQueueProvisioner, ListenerContainerCustomizer, MessageSourceCustomizer) - 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

rabbitMessageConverterHelper() - Method in class org.springframework.cloud.stream.binder.rabbit.config.MessageConverterHelperConfiguration

rabbitTemplate(RabbitTemplateConfigurer, ConnectionFactory) - Method in class org.springframework.cloud.stream.binder.rabbit.config.RabbitConfiguration

rabbitTemplateConfigurer(RabbitProperties, ObjectProvider, ObjectProvider) - Method in class org.springframework.cloud.stream.binder.rabbit.config.RabbitConfiguration

recover(List, Throwable) - Method in class org.springframework.cloud.stream.binder.rabbit.BatchCapableRejectAndDontRequeueRecoverer

recover(Message, Throwable) - Method in class org.springframework.cloud.stream.binder.rabbit.BatchCapableRejectAndDontRequeueRecoverer

registerHints(RuntimeHints, ClassLoader) - Method in class org.springframework.cloud.stream.binder.rabbit.aot.RabbitBinderRuntimeHints

ROUTING_KEY_HEADER - Static variable in class org.springframework.cloud.stream.binder.rabbit.RabbitExpressionEvaluatingInterceptor

Default name for routing key header.

S

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

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

Set a MessagePostProcessor to compress messages.

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

Set a MessagePostProcessor to decompress messages.

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

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

shouldFailIfCantConvert(Message) - Method in class org.springframework.cloud.stream.binder.rabbit.config.DefaultMessageConverterHelper

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

Utilities for stream components.

U

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

A B C D E G L M N O P R S U
All Classes and Interfaces|All Packages|Constant Field Values