|
Spring AMQP | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of AmqpException in org.springframework.amqp |
|---|
| Subclasses of AmqpException in org.springframework.amqp | |
|---|---|
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. as soon as possible) without rollback, and without consuming any more messages. |
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 | |
|---|---|
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. |
Object |
AmqpTemplate.convertSendAndReceive(Object message)
Basic RPC pattern with conversion. |
Object |
AmqpTemplate.convertSendAndReceive(Object message,
MessagePostProcessor messagePostProcessor)
Basic RPC pattern with conversion. |
Object |
AmqpTemplate.convertSendAndReceive(String routingKey,
Object message)
Basic RPC pattern with conversion. |
Object |
AmqpTemplate.convertSendAndReceive(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
Basic RPC pattern with conversion. |
Object |
AmqpTemplate.convertSendAndReceive(String exchange,
String routingKey,
Object message)
Basic RPC pattern with conversion. |
Object |
AmqpTemplate.convertSendAndReceive(String exchange,
String routingKey,
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(String queueName)
Receive a message if there is one from a specific queue. |
Object |
AmqpTemplate.receiveAndConvert()
Receive a message if there is one from a default queue and convert it to a Java object. |
Object |
AmqpTemplate.receiveAndConvert(String queueName)
Receive a message if there is one from a specific queue and convert it to a Java object. |
void |
AmqpTemplate.send(Message message)
Send a message to a default exchange with a default routing key. |
void |
AmqpTemplate.send(String routingKey,
Message message)
Send a message to a default exchange with a specific routing key. |
void |
AmqpTemplate.send(String exchange,
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(String routingKey,
Message message)
Basic RPC pattern. |
Message |
AmqpTemplate.sendAndReceive(String exchange,
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 | |
|---|---|
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 |
ConnectionFactory.createConnection()
|
| Uses of AmqpException in org.springframework.amqp.rabbit.core |
|---|
| Methods in org.springframework.amqp.rabbit.core that throw AmqpException | ||
|---|---|---|
void |
RabbitTemplate.convertAndSend(Object object)
|
|
void |
RabbitTemplate.convertAndSend(Object message,
MessagePostProcessor messagePostProcessor)
|
|
void |
RabbitTemplate.convertAndSend(String routingKey,
Object object)
|
|
void |
RabbitTemplate.convertAndSend(String routingKey,
Object object,
CorrelationData correlationData)
|
|
void |
RabbitTemplate.convertAndSend(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
|
|
void |
RabbitTemplate.convertAndSend(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
|
|
void |
RabbitTemplate.convertAndSend(String exchange,
String routingKey,
Object object)
|
|
void |
RabbitTemplate.convertAndSend(String exchange,
String routingKey,
Object object,
CorrelationData corrationData)
|
|
void |
RabbitTemplate.convertAndSend(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
|
|
void |
RabbitTemplate.convertAndSend(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
|
|
Object |
RabbitTemplate.convertSendAndReceive(Object message)
|
|
Object |
RabbitTemplate.convertSendAndReceive(Object message,
MessagePostProcessor messagePostProcessor)
|
|
Object |
RabbitTemplate.convertSendAndReceive(String routingKey,
Object message)
|
|
Object |
RabbitTemplate.convertSendAndReceive(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
|
|
Object |
RabbitTemplate.convertSendAndReceive(String exchange,
String routingKey,
Object message)
|
|
Object |
RabbitTemplate.convertSendAndReceive(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
|
|
void |
RabbitTemplate.correlationconvertAndSend(Object object,
CorrelationData correlationData)
|
|
|
RabbitOperations.execute(ChannelCallback<T> action)
|
|
Message |
RabbitTemplate.receive()
|
|
Object |
RabbitTemplate.receiveAndConvert()
|
|
Object |
RabbitTemplate.receiveAndConvert(String queueName)
|
|
void |
RabbitTemplate.send(Message message)
|
|
void |
RabbitTemplate.send(String routingKey,
Message message)
|
|
void |
RabbitTemplate.send(String exchange,
String routingKey,
Message message)
|
|
void |
RabbitTemplate.send(String exchange,
String routingKey,
Message message,
CorrelationData correlationData)
|
|
Message |
RabbitTemplate.sendAndReceive(Message message)
|
|
Message |
RabbitTemplate.sendAndReceive(String routingKey,
Message message)
|
|
Message |
RabbitTemplate.sendAndReceive(String exchange,
String routingKey,
Message message)
|
|
| Uses of AmqpException in org.springframework.amqp.rabbit.listener |
|---|
| Subclasses of AmqpException in org.springframework.amqp.rabbit.listener | |
|---|---|
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. |
| Methods in org.springframework.amqp.rabbit.listener that throw AmqpException | |
|---|---|
void |
BlockingQueueConsumer.start()
|
|
Spring AMQP | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||