public interface RabbitOperations extends AmqpTemplate, Lifecycle
| Modifier and Type | Interface and Description |
|---|---|
static interface |
RabbitOperations.OperationsCallback<T>
Callback for using the same channel for multiple RabbitTemplate
operations.
|
| Modifier and Type | Method and Description |
|---|---|
void |
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 |
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 |
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 |
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 |
convertAndSend(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
Convert a Java object to an Amqp
Message and send it to a specific exchange
with a specific routing key. |
Object |
convertSendAndReceive(Object message,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
Object |
convertSendAndReceive(Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
Object |
convertSendAndReceive(String routingKey,
Object message,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
Object |
convertSendAndReceive(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
Object |
convertSendAndReceive(String exchange,
String routingKey,
Object message,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
Object |
convertSendAndReceive(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(Object message,
CorrelationData correlationData,
ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(String routingKey,
Object message,
CorrelationData correlationData,
ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
default <T> T |
convertSendAndReceiveAsType(String exchange,
String routingKey,
Object message,
CorrelationData correlationData,
ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
void |
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. |
<T> T |
execute(ChannelCallback<T> action)
Execute the callback with a channel and reliably close the channel afterwards.
|
ConnectionFactory |
getConnectionFactory()
Return the connection factory for this operations.
|
default <T> T |
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 afterwards.
|
<T> T |
invoke(RabbitOperations.OperationsCallback<T> action,
com.rabbitmq.client.ConfirmCallback acks,
com.rabbitmq.client.ConfirmCallback nacks)
Invoke operations on the same channel.
|
default boolean |
isRunning() |
void |
send(String exchange,
String routingKey,
Message message,
CorrelationData correlationData)
Send a message to a specific exchange with a specific routing key.
|
default void |
start() |
default void |
stop() |
boolean |
waitForConfirms(long timeout)
Delegate to the underlying dedicated channel to wait for confirms.
|
void |
waitForConfirmsOrDie(long timeout)
Delegate to the underlying dedicated channel to wait for confirms.
|
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, receive, receive, receive, receive, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, send, send, send, sendAndReceive, sendAndReceive, sendAndReceive@Nullable <T> T execute(ChannelCallback<T> action) throws AmqpException
T - the return type.action - the call back.ChannelCallback.doInRabbit(com.rabbitmq.client.Channel).AmqpException - if one occurs.@Nullable default <T> T invoke(RabbitOperations.OperationsCallback<T> action) throws AmqpException
T - the return type.action - the call back.RabbitOperations.OperationsCallback.doInRabbit(RabbitOperations operations).AmqpException - if one occurs.@Nullable <T> T invoke(RabbitOperations.OperationsCallback<T> action, @Nullable com.rabbitmq.client.ConfirmCallback acks, @Nullable com.rabbitmq.client.ConfirmCallback nacks)
T - the return type.action - the callback.acks - a confirm callback for acks.nacks - a confirm callback for nacks.boolean waitForConfirms(long timeout)
throws AmqpException
invoke(OperationsCallback) operation.
Requires CachingConnectionFactory#setPublisherConfirms(true).timeout - the timeoutAmqpException - if one occurs.Channel.waitForConfirms(long)void waitForConfirmsOrDie(long timeout)
throws AmqpException
invoke(OperationsCallback) operation.
Requires CachingConnectionFactory#setPublisherConfirms(true).timeout - the timeoutAmqpException - if one occurs.Channel.waitForConfirmsOrDie(long)ConnectionFactory getConnectionFactory()
void send(String exchange, String routingKey, Message message, CorrelationData correlationData) throws AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problemvoid correlationConvertAndSend(Object message, CorrelationData correlationData) throws AmqpException
Message and send it to a default exchange
with a default routing key.message - a message to sendcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problemvoid convertAndSend(String routingKey, Object message, CorrelationData correlationData) throws AmqpException
Message and send it to a default exchange
with a specific routing key.routingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problemvoid convertAndSend(String exchange, String routingKey, Object message, CorrelationData correlationData) throws AmqpException
Message and send it to a specific exchange
with a specific routing key.exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problemvoid convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
Message and send it to a default exchange
with a default routing key.message - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problemvoid convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
Message and send it to a default exchange
with a specific routing key.routingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problemvoid convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
Message and send it to a specific exchange
with a specific routing key.exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problem@Nullable Object convertSendAndReceive(Object message, CorrelationData correlationData) throws AmqpException
message - a message to send.correlationData - data to correlate publisher confirms.AmqpException - if there is a problem@Nullable Object convertSendAndReceive(String routingKey, Object message, CorrelationData correlationData) throws AmqpException
routingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problem@Nullable Object convertSendAndReceive(String exchange, String routingKey, Object message, CorrelationData correlationData) throws AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problem@Nullable Object convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
message - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problem@Nullable Object convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
routingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problem@Nullable Object convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.AmqpException - if there is a problem@Nullable <T> T convertSendAndReceiveAsType(Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
SmartMessageConverter.T - the type.message - a message to send.correlationData - data to correlate publisher confirms.responseType - the type to convert the reply to.AmqpException - if there is a problem.@Nullable <T> T convertSendAndReceiveAsType(String routingKey, Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
SmartMessageConverter.T - the type.routingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.responseType - the type to convert the reply to.AmqpException - if there is a problem@Nullable default <T> T convertSendAndReceiveAsType(String exchange, String routingKey, Object message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
SmartMessageConverter.T - the type.exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.responseType - the type to convert the reply to.AmqpException - if there is a problem@Nullable <T> T convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
SmartMessageConverter.T - the type.message - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.responseType - the type to convert the reply to.AmqpException - if there is a problem@Nullable <T> T convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
SmartMessageConverter.T - the type.routingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.responseType - the type to convert the reply to.AmqpException - if there is a problem@Nullable <T> T convertSendAndReceiveAsType(String exchange, String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
SmartMessageConverter.T - the type.exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.responseType - the type to convert the reply to.AmqpException - if there is a problem