Uses of Class
org.springframework.amqp.AmqpException

Packages that use AmqpException

Package	Description
org.springframework.amqp	Base package for Spring AMQP.
org.springframework.amqp.core	Provides core classes for the spring AMQP abstraction.
org.springframework.amqp.rabbit.connection	Provides classes related to connections.
org.springframework.amqp.rabbit.core	Provides core classes for Spring Rabbit.
org.springframework.amqp.rabbit.listener	Provides classes for message listener containers.
org.springframework.amqp.rabbit.listener.adapter	Provides classes for adapting listeners.
org.springframework.amqp.rabbit.listener.exception	Provides classes for listener exceptions.
org.springframework.amqp.rabbit.support	Provides support classes for Spring Rabbit.
org.springframework.amqp.support.converter	Provides classes for supporting message conversion.
org.springframework.amqp.support.postprocessor	Package for Spring AMQP message post processors.
org.springframework.rabbit.stream.producer	Provides classes for stream producers.

Uses of AmqpException in org.springframework.amqp

Subclasses of AmqpException in org.springframework.amqp

Modifier and Type	Class	Description
class	AmqpApplicationContextClosedException	Thrown when the connection factory has been destroyed during context close; the factory can no longer open connections.
class	AmqpAuthenticationException	Runtime wrapper for an authentication exception.
class	AmqpConnectException	RuntimeException wrapper for an ConnectException which can be commonly thrown from AMQP operations if the remote process dies or there is a network issue.
class	AmqpIllegalStateException	Equivalent of an IllegalStateException but within the AmqpException hierarchy.
class	AmqpIOException	RuntimeException wrapper for an IOException which can be commonly thrown from AMQP operations.
class	AmqpRejectAndDontRequeueException	Exception for listener implementations used to indicate the basic.reject will be sent with requeue=false in order to enable features such as DLQ.
class	AmqpRemoteException	An exception that wraps an exception thrown by the server in a request/reply scenario.
class	AmqpResourceNotAvailableException	The AmqpException thrown when some resource can't be accessed.
class	AmqpTimeoutException	Exception thrown when some time-bound operation fails to execute in the desired time.
class	AmqpUnsupportedEncodingException	RuntimeException for unsupported encoding in an AMQP operation.
class	ImmediateAcknowledgeAmqpException	Special exception for listener implementations that want to signal that the current batch of messages should be acknowledged immediately (i.e.
class	ImmediateRequeueAmqpException	The special AmqpException to be thrown from the listener (e.g.
class	UncategorizedAmqpException	A "catch-all" exception type within the AmqpException hierarchy when no more specific cause is known.

Uses of AmqpException in org.springframework.amqp.core

Subclasses of AmqpException in org.springframework.amqp.core

Modifier and Type	Class	Description
class	AmqpMessageReturnedException	Exception thrown if the request message cannot be delivered when the mandatory flag is set.
class	AmqpReplyTimeoutException	Async reply timeout.

Methods in org.springframework.amqp.core that throw AmqpException

Modifier and Type	Method	Description
void	AmqpTemplate.convertAndSend(Object message)	Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
void	AmqpTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor)	Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
void	AmqpTemplate.convertAndSend(String routingKey, Object message)	Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
void	AmqpTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
void	AmqpTemplate.convertAndSend(String exchange, String routingKey, Object message)	Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
void	AmqpTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
@Nullable Object	AmqpTemplate.convertSendAndReceive(Object message)	Basic RPC pattern with conversion.
@Nullable Object	AmqpTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)	Basic RPC pattern with conversion.
@Nullable Object	AmqpTemplate.convertSendAndReceive(String routingKey, Object message)	Basic RPC pattern with conversion.
@Nullable Object	AmqpTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Basic RPC pattern with conversion.
@Nullable Object	AmqpTemplate.convertSendAndReceive(String exchange, String routingKey, Object message)	Basic RPC pattern with conversion.
@Nullable Object	AmqpTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)	Basic RPC pattern with conversion.
<T> @Nullable T	AmqpTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	AmqpTemplate.convertSendAndReceiveAsType(Object message, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	AmqpTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	AmqpTemplate.convertSendAndReceiveAsType(String routingKey, Object message, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	AmqpTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	AmqpTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
Message	MessagePostProcessor.postProcessMessage(Message message)	Change (or replace) the message.
@Nullable Message	AmqpTemplate.receive()	Receive a message if there is one from a default queue.
@Nullable Message	AmqpTemplate.receive(long timeoutMillis)	Receive a message from a default queue, waiting up to the specified wait time if necessary for a message to become available.
@Nullable Message	AmqpTemplate.receive(String queueName)	Receive a message if there is one from a specific queue.
@Nullable Message	AmqpTemplate.receive(String queueName, long timeoutMillis)	Receive a message from a specific queue, waiting up to the specified wait time if necessary for a message to become available.
@Nullable Object	AmqpTemplate.receiveAndConvert()	Receive a message if there is one from a default queue and convert it to a Java object.
@Nullable Object	AmqpTemplate.receiveAndConvert(long timeoutMillis)	Receive a message if there is one from a default queue and convert it to a Java object.
<T> @Nullable T	AmqpTemplate.receiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type)	Receive a message if there is one from a default queue and convert it to a Java object.
@Nullable Object	AmqpTemplate.receiveAndConvert(String queueName)	Receive a message if there is one from a specific queue and convert it to a Java object.
@Nullable Object	AmqpTemplate.receiveAndConvert(String queueName, long timeoutMillis)	Receive a message if there is one from a specific queue and convert it to a Java object.
<T> @Nullable T	AmqpTemplate.receiveAndConvert(String queueName, long timeoutMillis, ParameterizedTypeReference<T> type)	Receive a message if there is one from a specific queue and convert it to a Java object.
<T> @Nullable T	AmqpTemplate.receiveAndConvert(String queueName, ParameterizedTypeReference<T> type)	Receive a message if there is one from a specific queue and convert it to a Java object.
<T> @Nullable T	AmqpTemplate.receiveAndConvert(ParameterizedTypeReference<T> type)	Receive a message if there is one from a default queue and convert it to a Java object.
<R, S> boolean	AmqpTemplate.receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback)	Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from MessageProperties or to default exchange and default routingKey.
<R, S> boolean	AmqpTemplate.receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback, String replyExchange, String replyRoutingKey)	Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the provided exchange and routingKey.
<R, S> boolean	AmqpTemplate.receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)	Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from result of ReplyToAddressCallback.
<R, S> boolean	AmqpTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback)	Receive a message if there is one from a default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from MessageProperties or to default exchange and default routingKey.
<R, S> boolean	AmqpTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback, String replyExchange, String replyRoutingKey)	Receive a message if there is one from default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the provided exchange and routingKey.
<R, S> boolean	AmqpTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)	Receive a message if there is one from a default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from result of ReplyToAddressCallback.
void	AmqpTemplate.send(String exchange, String routingKey, Message message)	Send a message to a specific exchange with a specific routing key.
void	AmqpTemplate.send(String routingKey, Message message)	Send a message to a default exchange with a specific routing key.
void	AmqpTemplate.send(Message message)	Send a message to a default exchange with a default routing key.
@Nullable Message	AmqpTemplate.sendAndReceive(String exchange, String routingKey, Message message)	Basic RPC pattern.
@Nullable Message	AmqpTemplate.sendAndReceive(String routingKey, Message message)	Basic RPC pattern.
@Nullable Message	AmqpTemplate.sendAndReceive(Message message)	Basic RPC pattern.

Uses of AmqpException in org.springframework.amqp.rabbit.connection

Subclasses of AmqpException in org.springframework.amqp.rabbit.connection

Modifier and Type	Class	Description
class	AfterCompletionFailedException	Represents a failure to commit or rollback when performing afterCompletion after the primary transaction completes.
class	AutoRecoverConnectionNotCurrentlyOpenException	An exception thrown if the connection is an auto recover connection that is not currently open and is in the process of being recovered.

Methods in org.springframework.amqp.rabbit.connection that throw AmqpException

Modifier and Type	Method	Description
void	Connection.close()	Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
void	RabbitResourceHolder.commitAll()
com.rabbitmq.client.Channel	Connection.createChannel(boolean transactional)	Create a new channel, using an internally allocated channel number.
Connection	AbstractRoutingConnectionFactory.createConnection()
final Connection	CachingConnectionFactory.createConnection()
Connection	ConnectionFactory.createConnection()
Connection	LocalizedQueueConnectionFactory.createConnection()
Connection	PooledChannelConnectionFactory.createConnection()
Connection	ThreadChannelConnectionFactory.createConnection()

Uses of AmqpException in org.springframework.amqp.rabbit.core

Subclasses of AmqpException in org.springframework.amqp.rabbit.core

Modifier and Type	Class	Description
class	AmqpNackReceivedException	An exception thrown when a negative acknowledgement received after publishing a message.
class	ConsumeOkNotReceivedException	Thrown when a blocking receive operation is performed but the consumeOk was not received before the receive timeout.

Methods in org.springframework.amqp.rabbit.core that throw AmqpException

Modifier and Type	Method	Description
void	RabbitOperations.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
void	RabbitOperations.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
void	RabbitOperations.convertAndSend(String routingKey, Object message, CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
void	RabbitOperations.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
void	RabbitOperations.convertAndSend(String exchange, String routingKey, Object message, CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
void	RabbitTemplate.convertAndSend(Object object)
void	RabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(String routingKey, Object object)
void	RabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(String routingKey, Object object, CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(String exchange, String routingKey, Object object)
void	RabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(String exchange, String routingKey, Object object, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitOperations.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitOperations.convertSendAndReceive(Object message, CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitOperations.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitOperations.convertSendAndReceive(String routingKey, Object message, CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitOperations.convertSendAndReceive(String exchange, String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitOperations.convertSendAndReceive(String exchange, String routingKey, Object message, CorrelationData correlationData)	Basic RPC pattern with conversion.
@Nullable Object	RabbitTemplate.convertSendAndReceive(Object message)
@Nullable Object	RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)
@Nullable Object	RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitTemplate.convertSendAndReceive(Object message, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitTemplate.convertSendAndReceive(String routingKey, Object message)
@Nullable Object	RabbitTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
@Nullable Object	RabbitTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitTemplate.convertSendAndReceive(String routingKey, Object message, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message)
@Nullable Object	RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)
@Nullable Object	RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
@Nullable Object	RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, @Nullable CorrelationData correlationData)
<T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(Object message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(String routingKey, Object message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
default <T> @Nullable T	RabbitOperations.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)	Basic RPC pattern with conversion.
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(@Nullable String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(Object message, @Nullable MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(Object message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(Object message, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)
<T> @Nullable T	RabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, ParameterizedTypeReference<T> responseType)
void	RabbitOperations.correlationConvertAndSend(Object message, CorrelationData correlationData)	Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
void	RabbitTemplate.correlationConvertAndSend(Object object, CorrelationData correlationData)
<T> @Nullable T	RabbitOperations.execute(ChannelCallback<T> action)	Execute the callback with a channel and reliably close the channel afterward.
default <T> @Nullable T	RabbitOperations.invoke(RabbitOperations.OperationsCallback<T> action)	Invoke the callback and run all operations on the template argument in a dedicated thread-bound channel and reliably close the channel afterward.
@Nullable Message	RabbitTemplate.receive()
@Nullable Message	RabbitTemplate.receive(long timeoutMillis)
@Nullable Object	RabbitTemplate.receiveAndConvert()
@Nullable Object	RabbitTemplate.receiveAndConvert(long timeoutMillis)
<T> @Nullable T	RabbitTemplate.receiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type)
@Nullable Object	RabbitTemplate.receiveAndConvert(String queueName)
@Nullable Object	RabbitTemplate.receiveAndConvert(String queueName, long timeoutMillis)
<T> @Nullable T	RabbitTemplate.receiveAndConvert(String queueName, long timeoutMillis, ParameterizedTypeReference<T> type)
<T> @Nullable T	RabbitTemplate.receiveAndConvert(String queueName, ParameterizedTypeReference<T> type)
<T> @Nullable T	RabbitTemplate.receiveAndConvert(ParameterizedTypeReference<T> type)
<R, S> boolean	RabbitTemplate.receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback)
<R, S> boolean	RabbitTemplate.receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback, String replyExchange, String replyRoutingKey)
<R, S> boolean	RabbitTemplate.receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)
<R, S> boolean	RabbitTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback)
<R, S> boolean	RabbitTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback, String exchange, String routingKey)
<R, S> boolean	RabbitTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)
void	BatchingRabbitTemplate.send(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
void	RabbitOperations.send(String exchange, String routingKey, Message message, @Nullable CorrelationData correlationData)	Send a message to a specific exchange with a specific routing key.
default void	RabbitOperations.send(String routingKey, Message message, CorrelationData correlationData)	Send a message to the default exchange with a specific routing key.
void	RabbitTemplate.send(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
void	RabbitTemplate.send(String exchange, String routingKey, Message message)
void	RabbitTemplate.send(String routingKey, Message message)
void	RabbitTemplate.send(String routingKey, Message message, CorrelationData correlationData)
void	RabbitTemplate.send(Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message, @Nullable CorrelationData correlationData)
@Nullable Message	RabbitTemplate.sendAndReceive(String routingKey, Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(String routingKey, Message message, @Nullable CorrelationData correlationData)
@Nullable Message	RabbitTemplate.sendAndReceive(Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(Message message, @Nullable CorrelationData correlationData)
boolean	RabbitOperations.waitForConfirms(long timeout)	Delegate to the underlying dedicated channel to wait for confirms.
void	RabbitOperations.waitForConfirmsOrDie(long timeout)	Delegate to the underlying dedicated channel to wait for confirms.

Uses of AmqpException in org.springframework.amqp.rabbit.listener

Subclasses of AmqpException in org.springframework.amqp.rabbit.listener

Modifier and Type	Class	Description
class	QueuesNotAvailableException	This exception indicates that a consumer could not be started because none of its queues are available for listening.

Methods in org.springframework.amqp.rabbit.listener that throw AmqpException

Modifier and Type	Method	Description
void	BlockingQueueConsumer.start()

Uses of AmqpException in org.springframework.amqp.rabbit.listener.adapter

Subclasses of AmqpException in org.springframework.amqp.rabbit.listener.adapter

Modifier and Type	Class	Description
class	ReplyFailureException	Exception to be thrown when the reply of a message failed to be sent.

Uses of AmqpException in org.springframework.amqp.rabbit.listener.exception

Subclasses of AmqpException in org.springframework.amqp.rabbit.listener.exception

Modifier and Type	Class	Description
class	FatalListenerExecutionException	Exception to be thrown when the execution of a listener method failed with an irrecoverable problem.
class	FatalListenerStartupException	Exception to be thrown when the execution of a listener method failed on startup.
class	MessageRejectedWhileStoppingException	Exception class that indicates a rejected message on shutdown.

Uses of AmqpException in org.springframework.amqp.rabbit.support

Subclasses of AmqpException in org.springframework.amqp.rabbit.support

Modifier and Type	Class	Description
class	ListenerExecutionFailedException	Exception to be thrown when the execution of a listener method failed.

Uses of AmqpException in org.springframework.amqp.support.converter

Subclasses of AmqpException in org.springframework.amqp.support.converter

Modifier and Type	Class	Description
class	MessageConversionException	Exception to be thrown by message converters if they encounter a problem with converting a message or object.

Uses of AmqpException in org.springframework.amqp.support.postprocessor

Methods in org.springframework.amqp.support.postprocessor that throw AmqpException

Modifier and Type	Method	Description
Message	AbstractCompressingPostProcessor.postProcessMessage(Message message)
Message	AbstractDecompressingPostProcessor.postProcessMessage(Message message)
Message	DelegatingDecompressingPostProcessor.postProcessMessage(Message message)

Uses of AmqpException in org.springframework.rabbit.stream.producer

Subclasses of AmqpException in org.springframework.rabbit.stream.producer

Modifier and Type	Class	Description
class	StreamSendException	Used to complete the future exceptionally when sending fails.

Methods in org.springframework.rabbit.stream.producer that throw AmqpException

Modifier and Type	Method	Description
default void	RabbitStreamOperations.close()