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.
|
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.
|
Modifier and Type | Method and 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. |
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.
|
<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,
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(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,
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(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 . |
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.
|
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 |
ConnectionFactory.createConnection() |
Connection |
AbstractRoutingConnectionFactory.createConnection() |
Connection |
CachingConnectionFactory.createConnection() |
Modifier and Type | Method and Description |
---|---|
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 correlationData) |
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)
Deprecated.
|
void |
RabbitTemplate.correlationConvertAndSend(Object object,
CorrelationData correlationData) |
<T> T |
RabbitOperations.execute(ChannelCallback<T> action) |
Message |
RabbitTemplate.receive() |
Object |
RabbitTemplate.receiveAndConvert() |
Object |
RabbitTemplate.receiveAndConvert(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,
String exchange,
String routingKey) |
<R,S> boolean |
RabbitTemplate.receiveAndReply(String queueName,
ReceiveAndReplyCallback<R,S> callback) |
<R,S> boolean |
RabbitTemplate.receiveAndReply(String queueName,
ReceiveAndReplyCallback<R,S> callback,
ReplyToAddressCallback<S> replyToAddressCallback) |
<R,S> boolean |
RabbitTemplate.receiveAndReply(String queueName,
ReceiveAndReplyCallback<R,S> callback,
String replyExchange,
String replyRoutingKey) |
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) |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
BlockingQueueConsumer.start() |
Copyright © 2018. All rights reserved.