public interface RabbitOperations
extends org.springframework.amqp.core.AmqpTemplate
| 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(java.lang.Object message,
org.springframework.amqp.core.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(java.lang.String routingKey,
java.lang.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(java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.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(java.lang.String exchange,
java.lang.String routingKey,
java.lang.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(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
Convert a Java object to an Amqp
Message and send it to a specific exchange
with a specific routing key. |
java.lang.Object |
convertSendAndReceive(java.lang.Object message,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
java.lang.Object |
convertSendAndReceive(java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
java.lang.Object |
convertSendAndReceive(java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
java.lang.Object |
convertSendAndReceive(java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
java.lang.Object |
convertSendAndReceive(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
java.lang.Object |
convertSendAndReceive(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(java.lang.Object message,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
<T> T |
convertSendAndReceiveAsType(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
Basic RPC pattern with conversion.
|
void |
correlationConvertAndSend(java.lang.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.
|
<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.
|
void |
send(java.lang.String exchange,
java.lang.String routingKey,
org.springframework.amqp.core.Message message,
CorrelationData correlationData)
Send a message to a specific exchange with a specific routing key.
|
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<T> T execute(ChannelCallback<T> action) throws org.springframework.amqp.AmqpException
T - the return type.action - the call back.ChannelCallback.doInRabbit(com.rabbitmq.client.Channel).org.springframework.amqp.AmqpException - if one occurs.<T> T invoke(RabbitOperations.OperationsCallback<T> action) throws org.springframework.amqp.AmqpException
T - the return type.action - the call back.RabbitOperations.OperationsCallback.doInRabbit(RabbitOperations operations).org.springframework.amqp.AmqpException - if one occurs.boolean waitForConfirms(long timeout)
throws org.springframework.amqp.AmqpException
invoke(OperationsCallback) operation.
Requires CachingConnectionFactory#setPublisherConfirms(true).timeout - the timeoutorg.springframework.amqp.AmqpException - if one occurs.Channel.waitForConfirms(long)void waitForConfirmsOrDie(long timeout)
throws org.springframework.amqp.AmqpException
invoke(OperationsCallback) operation.
Requires CachingConnectionFactory#setPublisherConfirms(true).timeout - the timeoutorg.springframework.amqp.AmqpException - if one occurs.Channel.waitForConfirmsOrDie(long)ConnectionFactory getConnectionFactory()
void send(java.lang.String exchange,
java.lang.String routingKey,
org.springframework.amqp.core.Message message,
CorrelationData correlationData)
throws org.springframework.amqp.AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.org.springframework.amqp.AmqpException - if there is a problemvoid correlationConvertAndSend(java.lang.Object message,
CorrelationData correlationData)
throws org.springframework.amqp.AmqpException
Message and send it to a default exchange
with a default routing key.message - a message to sendcorrelationData - data to correlate publisher confirms.org.springframework.amqp.AmqpException - if there is a problemvoid convertAndSend(java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problemvoid convertAndSend(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problemvoid convertAndSend(java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problemvoid convertAndSend(java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problemvoid convertAndSend(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problemjava.lang.Object convertSendAndReceive(java.lang.Object message,
CorrelationData correlationData)
throws org.springframework.amqp.AmqpException
message - a message to send.correlationData - data to correlate publisher confirms.org.springframework.amqp.AmqpException - if there is a problemjava.lang.Object convertSendAndReceive(java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData)
throws org.springframework.amqp.AmqpException
routingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.org.springframework.amqp.AmqpException - if there is a problemjava.lang.Object convertSendAndReceive(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData)
throws org.springframework.amqp.AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendcorrelationData - data to correlate publisher confirms.org.springframework.amqp.AmqpException - if there is a problemjava.lang.Object convertSendAndReceive(java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
throws org.springframework.amqp.AmqpException
message - a message to sendmessagePostProcessor - a processor to apply to the message before it is sentcorrelationData - data to correlate publisher confirms.org.springframework.amqp.AmqpException - if there is a problemjava.lang.Object convertSendAndReceive(java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problemjava.lang.Object convertSendAndReceive(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problem<T> T convertSendAndReceiveAsType(java.lang.Object message,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
throws org.springframework.amqp.AmqpException
SmartMessageConverter.T - the type.message - a message to send.correlationData - data to correlate publisher confirms.responseType - the type to convert the reply to.org.springframework.amqp.AmqpException - if there is a problem.<T> T convertSendAndReceiveAsType(java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problem<T> T convertSendAndReceiveAsType(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problem<T> T convertSendAndReceiveAsType(java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problem<T> T convertSendAndReceiveAsType(java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problem<T> T convertSendAndReceiveAsType(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object message,
org.springframework.amqp.core.MessagePostProcessor messagePostProcessor,
CorrelationData correlationData,
org.springframework.core.ParameterizedTypeReference<T> responseType)
throws org.springframework.amqp.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.org.springframework.amqp.AmqpException - if there is a problem