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