Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractAmqpListenerEndpoint - Class in org.springframework.amqp.client.config
-
The abstract
AmqpListenerEndpointimplementation holding common properties. - AbstractAmqpListenerEndpoint(String...) - Constructor for class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
- AcknowledgingProtonDeliveryListener - Interface in org.springframework.amqp.client.listener
-
The
ProtonDeliveryListenerextension with anAmqpAcknowledgmentcallback 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
Advicebean 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
fromaddress. - AmqpClient.SendSpec - Interface in org.springframework.amqp.client
-
The fluent API for the send operation based on the message building blocks starting with
toaddress. - AmqpClient.SendSpec.ConvertAndSendSpec - Interface in org.springframework.amqp.client
-
The fluent API for the send operation based on the message building blocks starting with
toaddress. - 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
AmqpExceptionwrapper for the checkedClientException. - 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
Connectionmanagement. - AmqpDefaultConfiguration - Class in org.springframework.amqp.client.config
-
The
Configurationfor AMQP 1.0 infrastructure to supportAmqpListener. - 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
AmqpListenerto be invoked by an AMQP 1.0 message listener container created under the cover by aMethodAmqpMessageListenerContainerFactoryaccording 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
MessageListenerwith properties for targetAmqpMessageListenerContainerto be registered as a bean in the application context. - AmqpListenerEndpointRegistration - Class in org.springframework.amqp.client.config
-
The configuration container to trigger
AmqpMessageListenerContainerbean registrations based on the providedAmqpListenerEndpointinstances andAmqpMessageListenerContainerFactory. - 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
AmqpListenerEndpointRegistrationinstances. - 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
@AmqpListenermethod throws an exception. - AmqpListeners - Annotation Interface in org.springframework.amqp.client.annotation
-
Container annotation that aggregates several
AmqpListenerannotations. - AmqpMessageListenerContainer - Class in org.springframework.amqp.client.listener
-
The
MessageListenerContainerimplementation 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
AmqpMessageListenerContainerinstance based on the providedAmqpListenerEndpoint. - 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
ProtonDeliveryListenerimplementation for POJO listeners delegating to the providedHandlerAdapter. - 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
RuntimeHintsRegistrarforspring-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
autoAcceptproperty. - autoStartup() - Element in annotation interface org.springframework.amqp.client.annotation.AmqpListener
-
Set to
falseto 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.ConvertAndSendSpecfrom the provided body. - build() - Method in class org.springframework.amqp.client.AmqpClient.Builder
-
Build the
AmqpClientinstance 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
MethodAmqpMessageListenerContainerFactoryto 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
AmqpMessageListenerContainerinstance based on the providedAmqpListenerEndpoint. - 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)andAmqpClient.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
AmqpListenerErrorHandlerto 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
fromaddress. - 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
autoAcceptproperty in theAmqpMessageListenerContainerFactory. - getAutoStartup() - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
- getAutoStartup() - Method in interface org.springframework.amqp.client.config.AmqpListenerEndpoint
-
Override of the default
autoStartupproperty from theAmqpMessageListenerContainerFactory. - 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
receiveTimeoutfor 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
headerMapperused 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
MessageConverterfor 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
AbstractAmqpListenerEndpointimplementation 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
-
The
AmqpMessageListenerContainerFactoryextension forMethodAmqpListenerEndpoint. - 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
Deliveryand 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
Deliveryobjects. - protonMessage(Message) - Method in interface org.springframework.amqp.client.AmqpClient.SendSpec
-
Create a
AmqpClient.SendSpec.MessageSendSpecfrom 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
fromaddress. - receiveAndConvert(T...) - Method in interface org.springframework.amqp.client.AmqpClient.ReceiveSpec
-
Receive a message from the provided
fromaddress 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
fromaddress. - 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
AmqpMessageListenerContainerbean based on the providedAmqpListenerEndpoint. - registerListenerEndpoint(AmqpMessageListenerContainerFactory, AmqpListenerEndpoint) - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
-
Register
AmqpMessageListenerContainerbean based on the providedAmqpListenerEndpointandAmqpMessageListenerContainerFactory. - registerListenerEndpoints(AmqpListenerEndpointRegistration) - Method in class org.springframework.amqp.client.config.AmqpListenerEndpointRegistry
-
Register
AmqpMessageListenerContainerbeans based on the providedAmqpListenerEndpointRegistration. - 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
ReplyPostProcessorto 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
-
trueto cause exceptions thrown by the listener to be sent to the sender using normalreplyTo/@SendTosemantics.
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
SenderOptionsinstance in this builder. - senderOptions(SenderOptions) - Method in class org.springframework.amqp.client.AmqpClient.Builder
-
Set the
SenderOptionsfor an internal AMQP 1.0Sender. - 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
falseto propagate aMessageProperties.setAmqpAcknowledgment(AmqpAcknowledgment)for targetMessageListenermanual 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
BeanFactoryto 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
ConnectionOptionsinstance. - 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
AmqpListenerErrorHandlerto invoke if the listener method throws an exception. - setErrorHandler(AmqpListenerErrorHandler) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
-
Set the
AmqpListenerErrorHandlerto invoke if the listener method throws an exception. - setErrorHandler(ErrorHandler) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
-
The
ErrorHandlerfor 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
gracefulShutdownPeriodfor 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
AmqpHeaderMapperimplementation to use to map the standard AMQP headers. - setHeaderMapper(AmqpHeaderMapper) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
-
Set the
AmqpHeaderMapperimplementation to use to map the standard AMQP headers. - setHeaderMapper(AmqpHeaderMapper) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
-
Set the
AmqpHeaderMapperimplementation 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
AmqpListenerErrorHandlerto 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
MessageHandlerMethodFactoryto build anInvocableHandlerMethodfor the listener method. - setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
-
Set the
MessageHandlerMethodFactoryto configureMethodAmqpListenerEndpoint. - 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
receiveTimeoutfor 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
ReconnectOptionsfor the AMQP connection. - setRecoveryBackOff(BackOff) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
-
The default
BackOfffor a failed consumer recovery in container instances created by this factory. - setRecoveryBackOff(BackOff) - Method in class org.springframework.amqp.client.listener.AmqpMessageListenerContainer
-
Specify the
BackOfffor 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
ReplyPostProcessorto post process a response message before it is sent. - setReplyPostProcessor(ReplyPostProcessor) - Method in class org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
-
Set a
ReplyPostProcessorto post process a response message before it is sent. - setReplyPostProcessor(ReplyPostProcessor) - Method in class org.springframework.amqp.client.listener.AmqpMessagingListenerAdapter
-
Set a
ReplyPostProcessorto 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/@SendTosemantics. - 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/@SendTosemantics. - 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/@SendTosemantics. - setTaskExecutor(Executor) - Method in class org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint
- setTaskExecutor(Executor) - Method in class org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
-
The default
Executorfor 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
AbstractAmqpListenerEndpointimplementation forMessageListener. - SimpleAmqpListenerEndpoint(MessageListener, String...) - Constructor for class org.springframework.amqp.client.config.SimpleAmqpListenerEndpoint
- SingleAmqpConnectionFactory - Class in org.springframework.amqp.client
-
The
AmqpConnectionFactoryimplementation to hold a single, sharedConnectioninstance. - 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
TaskExecutorfor 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
toaddress. - toAmqpException(Exception) - Static method in class org.springframework.amqp.client.ProtonUtils
-
Wrap an exception to an
AmqpExceptionimplementation. - toAmqpException(ExecutionException) - Static method in class org.springframework.amqp.client.ProtonUtils
-
Wrap an
ExecutionExceptionto anAmqpExceptionimplementation. - toAmqpException(ClientException) - Static method in class org.springframework.amqp.client.ProtonUtils
-
Wrap an
ClientExceptionto anAmqpExceptionimplementation. - 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
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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form