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.

Uses of AmqpException in org.springframework.amqp

Subclasses of AmqpException in org.springframework.amqp

Modifier and Type	Class and Description
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	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	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

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

Modifier and Type	Method and Description
void	AmqpTemplate.convertAndSend(java.lang.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(java.lang.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(java.lang.String routingKey, java.lang.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(java.lang.String routingKey, java.lang.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(java.lang.String exchange, java.lang.String routingKey, java.lang.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(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor) Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
java.lang.Object	AmqpTemplate.convertSendAndReceive(java.lang.Object message) Basic RPC pattern with conversion.
java.lang.Object	AmqpTemplate.convertSendAndReceive(java.lang.Object message, MessagePostProcessor messagePostProcessor) Basic RPC pattern with conversion.
java.lang.Object	AmqpTemplate.convertSendAndReceive(java.lang.String routingKey, java.lang.Object message) Basic RPC pattern with conversion.
java.lang.Object	AmqpTemplate.convertSendAndReceive(java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor) Basic RPC pattern with conversion.
java.lang.Object	AmqpTemplate.convertSendAndReceive(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message) Basic RPC pattern with conversion.
java.lang.Object	AmqpTemplate.convertSendAndReceive(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor) Basic RPC pattern with conversion.
Message	MessagePostProcessor.postProcessMessage(Message message)
Message	AmqpTemplate.receive() Receive a message if there is one from a default queue.
Message	AmqpTemplate.receive(java.lang.String queueName) Receive a message if there is one from a specific queue.
java.lang.Object	AmqpTemplate.receiveAndConvert() Receive a message if there is one from a default queue and convert it to a Java object.
java.lang.Object	AmqpTemplate.receiveAndConvert(java.lang.String queueName) Receive a message if there is one from a specific queue and convert it to a Java object.
<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, 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.
<R,S> boolean	AmqpTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback, java.lang.String replyExchange, java.lang.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(java.lang.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(java.lang.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(java.lang.String queueName, ReceiveAndReplyCallback<R,S> callback, java.lang.String replyExchange, java.lang.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.
void	AmqpTemplate.send(Message message) Send a message to a default exchange with a default routing key.
void	AmqpTemplate.send(java.lang.String routingKey, Message message) Send a message to a default exchange with a specific routing key.
void	AmqpTemplate.send(java.lang.String exchange, java.lang.String routingKey, Message message) Send a message to a specific exchange with a specific routing key.
Message	AmqpTemplate.sendAndReceive(Message message) Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(java.lang.String routingKey, Message message) Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message) Basic RPC pattern.

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

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

Modifier and Type	Method and 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	CachingConnectionFactory.createConnection()
Connection	AbstractRoutingConnectionFactory.createConnection()
Connection	ConnectionFactory.createConnection()

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

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

Modifier and Type	Method and Description
void	RabbitTemplate.convertAndSend(java.lang.Object object)
void	RabbitTemplate.convertAndSend(java.lang.Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(java.lang.String routingKey, java.lang.Object object)
void	RabbitTemplate.convertAndSend(java.lang.String routingKey, java.lang.Object object, CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(java.lang.String exchange, java.lang.String routingKey, java.lang.Object object)
void	RabbitTemplate.convertAndSend(java.lang.String exchange, java.lang.String routingKey, java.lang.Object object, CorrelationData correlationData)
void	RabbitTemplate.convertAndSend(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.convertAndSend(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
java.lang.Object	RabbitTemplate.convertSendAndReceive(java.lang.Object message)
java.lang.Object	RabbitTemplate.convertSendAndReceive(java.lang.Object message, MessagePostProcessor messagePostProcessor)
java.lang.Object	RabbitTemplate.convertSendAndReceive(java.lang.String routingKey, java.lang.Object message)
java.lang.Object	RabbitTemplate.convertSendAndReceive(java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor)
java.lang.Object	RabbitTemplate.convertSendAndReceive(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message)
java.lang.Object	RabbitTemplate.convertSendAndReceive(java.lang.String exchange, java.lang.String routingKey, java.lang.Object message, MessagePostProcessor messagePostProcessor)
void	RabbitTemplate.correlationconvertAndSend(java.lang.Object object, CorrelationData correlationData) Deprecated.
void	RabbitTemplate.correlationConvertAndSend(java.lang.Object object, CorrelationData correlationData)
private <R,S> boolean	RabbitTemplate.doReceiveAndReply(java.lang.String queueName, ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)
<T> T	RabbitOperations.execute(ChannelCallback<T> action)
private Address	RabbitTemplate.getReplyToAddress(Message request) Determine a reply-to Address for the given message.
Message	RabbitTemplate.receive()
java.lang.Object	RabbitTemplate.receiveAndConvert()
java.lang.Object	RabbitTemplate.receiveAndConvert(java.lang.String queueName)
<R,S> boolean	RabbitTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback)
<R,S> boolean	RabbitTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)
<R,S> boolean	RabbitTemplate.receiveAndReply(ReceiveAndReplyCallback<R,S> callback, java.lang.String exchange, java.lang.String routingKey)
<R,S> boolean	RabbitTemplate.receiveAndReply(java.lang.String queueName, ReceiveAndReplyCallback<R,S> callback)
<R,S> boolean	RabbitTemplate.receiveAndReply(java.lang.String queueName, ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)
<R,S> boolean	RabbitTemplate.receiveAndReply(java.lang.String queueName, ReceiveAndReplyCallback<R,S> callback, java.lang.String replyExchange, java.lang.String replyRoutingKey)
void	RabbitTemplate.send(Message message)
void	RabbitTemplate.send(java.lang.String routingKey, Message message)
void	RabbitTemplate.send(java.lang.String exchange, java.lang.String routingKey, Message message)
void	RabbitTemplate.send(java.lang.String exchange, java.lang.String routingKey, Message message, CorrelationData correlationData)
Message	RabbitTemplate.sendAndReceive(Message message)
Message	RabbitTemplate.sendAndReceive(java.lang.String routingKey, Message message)
Message	RabbitTemplate.sendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message)

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

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

Modifier and Type	Class and Description
class	BlockingQueueConsumer.DeclarationException
class	FatalListenerExecutionException Exception to be thrown when the execution of a listener method failed unrecoverably.
class	FatalListenerStartupException Exception to be thrown when the execution of a listener method failed on startup.
class	ListenerExecutionFailedException Exception to be thrown when the execution of a listener method failed.
class	MessageRejectedWhileStoppingException Exception class that indicates a rejected message on shutdown.
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 and Description
void	BlockingQueueConsumer.start()