Index

A B C D E F G H I M O P R S T U V 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractAmqpListenerEndpoint - Class in org.springframework.amqp.client.config
The abstract AmqpListenerEndpoint implementation holding common properties.
AbstractAmqpListenerEndpoint(String...) - Constructor for class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
AcknowledgingProtonDeliveryListener - Interface in org.springframework.amqp.client.listener
The ProtonDeliveryListener extension with an AmqpAcknowledgment callback provided from the container.
addEndpoint(AmqpListenerEndpoint) - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistration
 
addresses() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
The AMQP 1.0 addresses to listen to.
adviceChain() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
The Advice bean names to apply to the listener container.
afterPropertiesSet() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
afterSingletonsInstantiated() - Method in class org.springframework.amqp.client.annotation.AmqpListenerAnnotationBeanPostProcessor
 
AMQP_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME - Static variable in class org.springframework.amqp.client.config.AmqpDefaultConfiguration
The bean name of the default AmqpMessageListenerContainerFactory.
AmqpClient - Interface in org.springframework.amqp.client
The fluent API for the AMQP 1.0 client.
AmqpClient.Builder - Class in org.springframework.amqp.client
 
AmqpClient.ReceiveSpec - Interface in org.springframework.amqp.client
The fluent API for the receiving operation based on the from address.
AmqpClient.SendSpec - Interface in org.springframework.amqp.client
The fluent API for the send operation based on the message building blocks starting with to address.
AmqpClient.SendSpec.ConvertAndSendSpec - Interface in org.springframework.amqp.client
The fluent API for the send operation based on the message building blocks starting with to address.
AmqpClient.SendSpec.MessageSendSpec - Interface in org.springframework.amqp.client
The last step in the fluent API for the send operation.
AmqpClientException - Exception Class in org.springframework.amqp.client
The AmqpException wrapper for the checked ClientException.
AmqpClientException(String, ClientException) - Constructor for exception class org.springframework.amqp.client.AmqpClientException
 
AmqpClientException(ClientException) - Constructor for exception class org.springframework.amqp.client.AmqpClientException
 
AmqpClientNackReceivedException - Exception Class in org.springframework.amqp.client
An exception thrown when a negative acknowledgement is received after publishing a message.
AmqpClientNackReceivedException(String, Message) - Constructor for exception class org.springframework.amqp.client.AmqpClientNackReceivedException
Create an instance with the provided message and failed message.
AmqpConnectionFactory - Interface in org.springframework.amqp.client
The contract for AMQP 1.0 Qpid ProtonJ2 Connection management.
AmqpDefaultConfiguration - Class in org.springframework.amqp.client.config
The Configuration for AMQP 1.0 infrastructure to support AmqpListener.
AmqpDefaultConfiguration() - Constructor for class org.springframework.amqp.client.config.AmqpDefaultConfiguration
 
AmqpListener - Annotation Interface in org.springframework.amqp.client.annotation
Annotation that marks a method to be the target of an AMQP 1.0 message listener on the specified AmqpListener.addresses().
AmqpListenerAnnotationBeanPostProcessor - Class in org.springframework.amqp.client.annotation
Bean post-processor that registers methods annotated with AmqpListener to be invoked by an AMQP 1.0 message listener container created under the cover by a MethodAmqpMessageListenerContainerFactory according to the parameters of the annotation.
AmqpListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.amqp.client.annotation.AmqpListenerAnnotationBeanPostProcessor
 
AmqpListenerEndpoint - Interface in org.springframework.amqp.client.config
The configuration model to represent a MessageListener with properties for target AmqpMessageListenerContainer to be registered as a bean in the application context.
AmqpListenerEndpointRegistration - Class in org.springframework.amqp.client.config
The configuration container to trigger AmqpMessageListenerContainer bean registrations based on the provided AmqpListenerEndpoint instances and AmqpMessageListenerContainerFactory.
AmqpListenerEndpointRegistration(AmqpListenerEndpoint...) - Constructor for class org.springframework.amqp.client.config.AmqpListenerEndpointRegistration
 
AmqpListenerEndpointRegistration(AmqpMessageListenerContainerFactory, AmqpListenerEndpoint...) - Constructor for class org.springframework.amqp.client.config.AmqpListenerEndpointRegistration
 
AmqpListenerEndpointRegistry - Class in org.springframework.amqp.client.config
An infrastructure bean to process AmqpListenerEndpointRegistration instances.
AmqpListenerEndpointRegistry() - Constructor for class org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
 
AmqpListenerEndpointRegistry(AmqpMessageListenerContainerFactory) - Constructor for class org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
 
AmqpListenerErrorHandler - Interface in org.springframework.amqp.client.listener
An error handler which is called when a @AmqpListener method throws an exception.
AmqpListeners - Annotation Interface in org.springframework.amqp.client.annotation
Container annotation that aggregates several AmqpListener annotations.
AmqpMessageListenerContainer - Class in org.springframework.amqp.client.listener
The MessageListenerContainer implementation for AMQP 1.0 protocol.
AmqpMessageListenerContainer(AmqpConnectionFactory) - Constructor for class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
AmqpMessageListenerContainerFactory - Class in org.springframework.amqp.client.config
The configuration factory to produce AmqpMessageListenerContainer instance based on the provided AmqpListenerEndpoint.
AmqpMessageListenerContainerFactory(AmqpConnectionFactory) - Constructor for class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
Create an instance with the provided AmqpConnectionFactory.
AmqpMessagingListenerAdapter - Class in org.springframework.amqp.client.listener
The ProtonDeliveryListener implementation for POJO listeners delegating to the provided HandlerAdapter.
AmqpMessagingListenerAdapter(HandlerAdapter) - Constructor for class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Create an instance based on the provided HandlerAdapter.
AmqpRuntimeHints - Class in org.springframework.amqp.client.aot
The RuntimeHintsRegistrar for spring-amqp-client.
AmqpRuntimeHints() - Constructor for class org.springframework.amqp.client.aot.AmqpRuntimeHints
 
autoAccept() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Override the container factory autoAccept property.
autoStartup() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Set to false to not auto start, to override the default setting in the container factory.

B

body(Object) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec
Create a AmqpClient.SendSpec.ConvertAndSendSpec from the provided body.
build() - Method in class org.springframework.amqp.client.AmqpClient.Builder
Build the AmqpClient instance based on the provided options.
builder(AmqpConnectionFactory) - Static method in interface org.springframework.amqp.client.AmqpClient
 
buildMetadata(Class) - Method in class org.springframework.amqp.client.annotation.AmqpListenerAnnotationBeanPostProcessor
 

C

completionTimeout(Duration) - Method in class org.springframework.amqp.client.AmqpClient.Builder
Set a duration for CompletableFuture.orTimeout(long, TimeUnit) on returns.
concurrency() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Set the concurrency of the listener container for this listener.
configureEndpoint(AmqpListenerEndpoint) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
 
configureEndpoint(AmqpListenerEndpoint) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
 
containerAckMode(AcknowledgeMode) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
 
containerFactory() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
The bean name of the MethodAmqpMessageListenerContainerFactory to use to create the message listener container responsible to serve this endpoint.
contentEncoding(String) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 
contentType(String) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 
correlationId(String) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 
create(AmqpConnectionFactory) - Static method in interface org.springframework.amqp.client.AmqpClient
 
createContainer(AmqpListenerEndpoint) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
Create a AmqpMessageListenerContainer instance based on the provided AmqpListenerEndpoint.
creationTime(Date) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 

D

DEFAULT_AMQP_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.amqp.client.config.AmqpDefaultConfiguration
The bean name of the default AmqpMessageListenerContainerFactory.
defaultRequeueRejected() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Set the default behavior for messages rejection.
defaultToAddress(String) - Method in class org.springframework.amqp.client.AmqpClient.Builder
Set the default target AMQP 1.0 address for the AmqpClient.sendToDefault(org.springframework.amqp.core.Message) and AmqpClient.send(Message) operations.
destroy() - Method in class org.springframework.amqp.client.SingleAmqpConnectionFactory
 
doProcessAmqpListener(AmqpListener, Method, Object, String) - Method in class org.springframework.amqp.client.annotation.AmqpListenerAnnotationBeanPostProcessor
 
durable(boolean) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 

E

EnableAmqp - Annotation Interface in org.springframework.amqp.client.config
Enable AMQP 1.0 infrastructure beans for AmqpListener.
errorHandler() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Set an AmqpListenerErrorHandler to invoke if the listener method throws an exception.
executor() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Set the task executor bean name to use for the listener container; overrides any executor set on the container factory.

F

from(String) - Method in interface org.springframework.amqp.client.AmqpClient
The fluent API for the receiving operation based on the from address.
fromProtonMessage(Message) - Static method in class org.springframework.amqp.client.ProtonUtils
Convert a ProtonJ message to the Spring AMQP message.

G

getAddresses() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getAddresses() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
Return the AMQP addresses to listen to.
getAdviceChain() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getAdviceChain() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
The advice chain for the target listener container bean.
getAutoAccept() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getAutoAccept() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
Override the autoAccept property in the AmqpMessageListenerContainerFactory.
getAutoStartup() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getAutoStartup() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
Override of the default autoStartup property from the AmqpMessageListenerContainerFactory.
getConcurrency() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getConcurrency() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
Return the concurrency (consumers per AMQP address) for the target listener container bean.
getConnection() - Method in interface org.springframework.amqp.client.AmqpConnectionFactory
 
getConnection() - Method in class org.springframework.amqp.client.SingleAmqpConnectionFactory
 
getContainerFactory() - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistration
 
getEndpoints() - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistration
 
getErrorHandler() - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
 
getFailedMessage() - Method in exception class org.springframework.amqp.client.AmqpClientNackReceivedException
Return the failed message.
getGracefulShutdownPeriod() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getGracefulShutdownPeriod() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
The graceful shutdown period for the target listener container bean.
getHeaderMapper() - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
 
getId() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getId() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
Return the id of the target listener container bean.
getInitialCredits() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getInitialCredits() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
The initial number of credits to grant to the AMQP receiver.
getListenerId() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
The 'id' attribute of the listener.
getMessageConverter() - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
 
getMessageListener() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
Return the message listener to be used in the target listener container bean.
getMessageListener() - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
 
getMessageListener() - Method in class org.springframework.amqp.client.config.SimpleAmqpListenerEndpoint
 
getMessageListener() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
getReceiveTimeout() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getReceiveTimeout() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
The receiveTimeout for the target listener container bean.
getReplyContentType() - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
 
getReplyPostProcessor() - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
 
getTaskExecutor() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
getTaskExecutor() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
Get the task executor for the target listener container bean.
gracefulShutdownPeriod() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
A duration for how long to wait for all the consumers to shut down successfully on listener container stop.

H

handleError(Delivery, Message, ListenerExecutionFailedException) - Method in interface org.springframework.amqp.client.listener.AmqpListenerErrorHandler
Handle the error.
header(String, Object) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 
headerMapper() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Override the container factory's headerMapper used for this listener.

I

id() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
The unique identifier of the container managing for this endpoint.
initialCredits() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
The initial number of credits to grant to the AMQP receiver.
isAsyncReplies() - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
 
isAutoStartup() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
isDefaultRequeueRejected() - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
 
isReturnExceptions() - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
 
isRunning() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 

M

message(Message) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec
 
messageConverter() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Override the container factory's message converter used for this listener.
messageConverter(MessageConverter) - Method in class org.springframework.amqp.client.AmqpClient.Builder
Set the MessageConverter for converting to/from message body.
messageId(String) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 
MethodAmqpListenerEndpoint - Class in org.springframework.amqp.client.config
The AbstractAmqpListenerEndpoint implementation for POJO method invocation listener.
MethodAmqpListenerEndpoint(Object, Method, String...) - Constructor for class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Create an instance for the method to invoke on the provided bean.
MethodAmqpMessageListenerContainerFactory - Class in org.springframework.amqp.client.config
MethodAmqpMessageListenerContainerFactory(AmqpConnectionFactory) - Constructor for class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Create an instance with the provided AmqpConnectionFactory.

O

onDelivery(Delivery) - Method in interface org.springframework.amqp.client.listener.AcknowledgingProtonDeliveryListener
 
onDelivery(Delivery) - Method in interface org.springframework.amqp.client.listener.ProtonDeliveryListener
Process ProtonJ Delivery.
onDelivery(Delivery, AmqpAcknowledgment) - Method in interface org.springframework.amqp.client.listener.AcknowledgingProtonDeliveryListener
Process ProtonJ Delivery and optionally acknowledge it with a callback from the listener container.
onDelivery(Delivery, AmqpAcknowledgment) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
 
onMessage(Message) - Method in interface org.springframework.amqp.client.listener.ProtonDeliveryListener
 
org.springframework.amqp.client - package org.springframework.amqp.client
Provides Spring Client for AMQP 1.0 protocol.
org.springframework.amqp.client.annotation - package org.springframework.amqp.client.annotation
Annotations and supporting classes for declarative AMQP 1.0 listener endpoints.
org.springframework.amqp.client.aot - package org.springframework.amqp.client.aot
Provides classes to support AOT for Spring AMQP 1.0.
org.springframework.amqp.client.config - package org.springframework.amqp.client.config
Provides classes for annotation-based Spring configuration.
org.springframework.amqp.client.listener - package org.springframework.amqp.client.listener
Provides Spring Listener Container for AMQP 1.0 protocol.

P

pause() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Pause all the consumers for all queues.
pause(String) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Pause all the consumers for the specific queue.
priority(int) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 
processMultiMethodListeners(List, List, Object, String) - Method in class org.springframework.amqp.client.annotation.AmqpListenerAnnotationBeanPostProcessor
 
ProtonDeliveryListener - Interface in org.springframework.amqp.client.listener
A message listener extension to process ProtonJ native Delivery objects.
protonMessage(Message) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec
Create a AmqpClient.SendSpec.MessageSendSpec from a ProtonJ message instance.
ProtonUtils - Class in org.springframework.amqp.client
Utility methods between ProtonJ and Spring API.

R

receive() - Method in interface org.springframework.amqp.client.AmqpClient.ReceiveSpec
Receive a Spring AMQP message from the provided from address.
receiveAndConvert(T...) - Method in interface org.springframework.amqp.client.AmqpClient.ReceiveSpec
Receive a message from the provided from address and convert its body to the provided generic type.
receiveProtonMessage() - Method in interface org.springframework.amqp.client.AmqpClient.ReceiveSpec
Receive a native ProtonJ message from the provided from address.
receiveTimeout() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
The timeout for deliveries from the broker in the target AMQP consumer.
registerHints(RuntimeHints, ClassLoader) - Method in class org.springframework.amqp.client.aot.AmqpRuntimeHints
 
registerListenerEndpoint(AmqpListenerEndpoint) - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
Register AmqpMessageListenerContainer bean based on the provided AmqpListenerEndpoint.
registerListenerEndpoint(AmqpMessageListenerContainerFactory, AmqpListenerEndpoint) - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
registerListenerEndpoints(AmqpListenerEndpointRegistration) - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
replyContentType() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
Used to set the content-type of a reply message.
replyPostProcessor() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
The bean name of a ReplyPostProcessor to post process a response before it is sent.
replyTo(String) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 
resume() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Resume all the consumers for all queues.
resume(String) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Resume all the consumers for the specific queue.
returnExceptions() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
true to cause exceptions thrown by the listener to be sent to the sender using normal replyTo/@SendTo semantics.

S

send() - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
Perform the send operation of the message built from the properties provided above.
send() - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.MessageSendSpec
Perform the send operation of the message provided in the previous step from AmqpClient.SendSpec.
send(Message) - Method in interface org.springframework.amqp.client.AmqpClient
Send a ProtonJ message instance.
senderOptions(Consumer) - Method in class org.springframework.amqp.client.AmqpClient.Builder
Customize the SenderOptions instance in this builder.
senderOptions(SenderOptions) - Method in class org.springframework.amqp.client.AmqpClient.Builder
Set the SenderOptions for an internal AMQP 1.0 Sender.
sendToDefault(Message) - Method in interface org.springframework.amqp.client.AmqpClient
Send a Spring AMQP message.
setAdviceChain(Advice...) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setAdviceChain(Advice...) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
Set The default advice chain for container instances created by this factory.
setAdviceChain(Advice...) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Set an advice chain to apply to the listener.
setApplicationContext(ApplicationContext) - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
 
setAutoAccept(boolean) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setAutoAccept(boolean) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default auto accept flag for container instances created by this factory.
setAutoAccept(boolean) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Set to false to propagate a MessageProperties.setAmqpAcknowledgment(AmqpAcknowledgment) for target MessageListener manual acknowledgement.
setAutoStartup(boolean) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setAutoStartup(boolean) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default auto startup flag for container instances created by this factory.
setAutoStartup(boolean) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
setBeanFactory(BeanFactory) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Provide a BeanFactory to use for resolving expressions in the listener method.
setBeanFactory(BeanFactory) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
 
setBeanName(String) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
setBeanResolver(BeanResolver) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set a bean resolver for runtime SpEL expressions.
setCharset(Charset) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set a charset for byte[] to String method argument conversion.
setConcurrency(int) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setConcurrency(int) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default concurrency for container instances created by this factory.
setConnectionOptions(ConnectionOptions) - Method in class org.springframework.amqp.client.SingleAmqpConnectionFactory
Set a ConnectionOptions instance.
setConsumersPerQueue(int) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Each queue runs in its own consumer; set this property to create multiple consumers for each queue.
setCustomMethodArgumentResolvers(HandlerMethodArgumentResolver...) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Add custom methods arguments resolvers the default message handler factory.
setDefaultRequeueRejected(boolean) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Set the default behavior for messages rejection, for example, when the listener throws an exception.
setDefaultRequeueRejected(boolean) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set the default behavior for messages rejection, for example, when the listener threw an exception.
setDefaultRequeueRejected(boolean) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set the default behavior for messages rejection, for example, when the listener threw an exception.
setErrorHandler(AmqpListenerErrorHandler) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Set the AmqpListenerErrorHandler to invoke if the listener method throws an exception.
setErrorHandler(AmqpListenerErrorHandler) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set the AmqpListenerErrorHandler to invoke if the listener method throws an exception.
setErrorHandler(ErrorHandler) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The ErrorHandler for container instances created by this factory.
setErrorHandler(ErrorHandler) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
setGracefulShutdownPeriod(Duration) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setGracefulShutdownPeriod(Duration) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default gracefulShutdownPeriod for container instances created by this factory.
setGracefulShutdownPeriod(Duration) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Set a duration for how long to wait for all the consumers to shut down successfully on listener container stop.
setHeaderMapper(AmqpHeaderMapper) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Set the AmqpHeaderMapper implementation to use to map the standard AMQP headers.
setHeaderMapper(AmqpHeaderMapper) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set the AmqpHeaderMapper implementation to use to map the standard AMQP headers.
setHeaderMapper(AmqpHeaderMapper) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set the AmqpHeaderMapper implementation to use to map the standard AMQP headers.
setHost(String) - Method in class org.springframework.amqp.client.SingleAmqpConnectionFactory
 
setId(String) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setInitialCredits(int) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setInitialCredits(int) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default initial credits value for container instances created by this factory.
setInitialCredits(int) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
The initial number of credits to grant to the AMQP receiver.
setListenerErrorHandler(AmqpListenerErrorHandler) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set the AmqpListenerErrorHandler to invoke if the listener method throws an exception.
setListenerId(String) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Set the converter to convert incoming messages to listener method arguments, and objects returned from listener methods for response messages.
setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set the converter to convert incoming messages to listener method arguments, and objects returned from listener methods for response messages.
setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set the converter to convert incoming messages to listener method arguments, and objects returned from listener methods for response messages.
setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Set the MessageHandlerMethodFactory to build an InvocableHandlerMethod for the listener method.
setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set the MessageHandlerMethodFactory to configure MethodAmqpListenerEndpoint.
setPassword(String) - Method in class org.springframework.amqp.client.SingleAmqpConnectionFactory
Set the password for the AMQP connection.
setPort(int) - Method in class org.springframework.amqp.client.SingleAmqpConnectionFactory
 
setQueueNames(String...) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
setReceiveTimeout(Duration) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setReceiveTimeout(Duration) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default receiveTimeout for container instances created by this factory.
setReceiveTimeout(Duration) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Set the timeout for deliveries from the broker in the AmqpMessageListenerContainer.AmqpConsumer.
setReconnectOptions(ReconnectOptions) - Method in class org.springframework.amqp.client.SingleAmqpConnectionFactory
Set the ReconnectOptions for the AMQP connection.
setRecoveryBackOff(BackOff) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default BackOff for a failed consumer recovery in container instances created by this factory.
setRecoveryBackOff(BackOff) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Specify the BackOff for a failed consumer recovery.
setRecoveryInterval(Duration) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default recovery interval for container instances created by this factory.
setRecoveryInterval(Duration) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Set an interval between recovery attempts of a failed consumer.
setReplyContentType(String) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Set the reply content type.
setReplyContentType(String) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set the reply content type.
setReplyContentType(String) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set the reply content type.
setReplyPostProcessor(ReplyPostProcessor) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Set a ReplyPostProcessor to post process a response message before it is sent.
setReplyPostProcessor(ReplyPostProcessor) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set a ReplyPostProcessor to post process a response message before it is sent.
setReplyPostProcessor(ReplyPostProcessor) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set a ReplyPostProcessor to post process a response message before it is sent.
setResponseAddress(String) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set the default replyTo address to use when sending response messages.
setReturnExceptions(boolean) - Method in class org.springframework.amqp.client.config.MethodAmqpListenerEndpoint
Set whether exceptions thrown by the listener should be returned as a response message body to the sender using the normal replyTo/@SendTo semantics.
setReturnExceptions(boolean) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set whether exceptions thrown by the listener should be returned as a response message body to the sender using the normal replyTo/@SendTo semantics.
setReturnExceptions(boolean) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
Set whether exceptions thrown by the listener should be returned as a response message body to the sender using the normal replyTo/@SendTo semantics.
setTaskExecutor(Executor) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
 
setTaskExecutor(Executor) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
The default Executor for container instances created by this factory.
setTaskExecutor(Executor) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
Set a task executor to run consumers.
setupMessageListener(MessageListener) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
setUsername(String) - Method in class org.springframework.amqp.client.SingleAmqpConnectionFactory
Set the username for the AMQP connection.
setValidator(Validator) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
Set the validator to use if the default message handler factory is used.
SimpleAmqpListenerEndpoint - Class in org.springframework.amqp.client.config
The AbstractAmqpListenerEndpoint implementation for MessageListener.
SimpleAmqpListenerEndpoint(MessageListener, String...) - Constructor for class org.springframework.amqp.client.config.SimpleAmqpListenerEndpoint
 
SingleAmqpConnectionFactory - Class in org.springframework.amqp.client
The AmqpConnectionFactory implementation to hold a single, shared Connection instance.
SingleAmqpConnectionFactory() - Constructor for class org.springframework.amqp.client.SingleAmqpConnectionFactory
Create an instance based on a default client.
SingleAmqpConnectionFactory(Client) - Constructor for class org.springframework.amqp.client.SingleAmqpConnectionFactory
Create an instance based on the provided Client.
start() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
stop() - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 
stop(Runnable) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
 

T

taskExecutor(TaskExecutor) - Method in class org.springframework.amqp.client.AmqpClient.Builder
Set the TaskExecutor for asynchronous operations.
timeout(Duration) - Method in interface org.springframework.amqp.client.AmqpClient.ReceiveSpec
Set a timeout for the delivery.
timeToLive(Duration) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 
to(String) - Method in interface org.springframework.amqp.client.AmqpClient
The fluent API for the send operation based on the message building blocks starting with to address.
toAmqpException(Exception) - Static method in class org.springframework.amqp.client.ProtonUtils
Wrap an exception to an AmqpException implementation.
toAmqpException(ExecutionException) - Static method in class org.springframework.amqp.client.ProtonUtils
Wrap an ExecutionException to an AmqpException implementation.
toAmqpException(ClientException) - Static method in class org.springframework.amqp.client.ProtonUtils
Wrap an ClientException to an AmqpException implementation.
toProtonMessage(Message) - Static method in class org.springframework.amqp.client.ProtonUtils
Convert a Spring AMQP message to a ProtonJ message.
toSupplier(Future, long) - Static method in class org.springframework.amqp.client.ProtonUtils
Convert a Future to a Supplier.

U

userId(String) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec.ConvertAndSendSpec
 

V

value() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListeners
 
A B C D E F G H I M O P R S T U V 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form