public class RabbitMessagingTemplate extends AbstractMessagingTemplate<String> implements RabbitMessageOperations, InitializingBean
RabbitMessageOperations
.CONVERSION_HINT_HEADER, logger
Constructor and Description |
---|
RabbitMessagingTemplate()
Constructor for use with bean properties.
|
RabbitMessagingTemplate(RabbitTemplate rabbitTemplate)
Create an instance with the
RabbitTemplate to use. |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
protected MessagingException |
convertAmqpException(RuntimeException ex) |
protected Message<?> |
convertAmqpMessage(Message message) |
void |
convertAndSend(String exchange,
String routingKey,
Object payload)
Convert the given Object to serialized form, possibly using a
MessageConverter ,
wrap it as a message and send it to a specific exchange with a
specific routing key. |
void |
convertAndSend(String exchange,
String routingKey,
Object payload,
Map<String,Object> headers)
Convert the given Object to serialized form, possibly using a
MessageConverter ,
wrap it as a message with the given headers and send it to a
specific exchange with a specific routing key. |
void |
convertAndSend(String exchange,
String routingKey,
Object payload,
Map<String,Object> headers,
MessagePostProcessor postProcessor)
Convert the given Object to serialized form, possibly using a
MessageConverter ,
wrap it as a message with the given headers, apply the given post processor,
and send the resulting message to a specific exchange with a specific
routing key. |
void |
convertAndSend(String exchange,
String routingKey,
Object payload,
MessagePostProcessor postProcessor)
Convert the given Object to serialized form, possibly using a
MessageConverter ,
wrap it as a message, apply the given post processor, and send
the resulting message to a specific exchange with a specific
routing key. |
<T> T |
convertSendAndReceive(String exchange,
String routingKey,
Object request,
Class<T> targetClass)
Convert the given request Object to serialized form, possibly using a
MessageConverter , send
it as a Message to a specific exchange with a specific routing key,
receive the reply and convert its body of the specified target class. |
<T> T |
convertSendAndReceive(String exchange,
String routingKey,
Object request,
Class<T> targetClass,
MessagePostProcessor requestPostProcessor)
Convert the given request Object to serialized form, possibly using a
MessageConverter ,
apply the given post processor and send the resulting Message to
a specific exchange with a specific routing key, receive the reply and
convert its body of the given target class. |
<T> T |
convertSendAndReceive(String exchange,
String routingKey,
Object request,
Map<String,Object> headers,
Class<T> targetClass)
Convert the given request Object to serialized form, possibly using a
MessageConverter , send
it as a Message with the given headers, to a specific exchange
with a specific routing key, receive the reply and convert its body of
the specified target class. |
<T> T |
convertSendAndReceive(String exchange,
String routingKey,
Object request,
Map<String,Object> headers,
Class<T> targetClass,
MessagePostProcessor requestPostProcessor)
Convert the given request Object to serialized form, possibly using a
MessageConverter ,
wrap it as a message with the given headers, apply the given post processor
and send the resulting Message to a specific exchange with a
specific routing key,, receive the reply and convert its body of the
given target class. |
protected Message<?> |
doReceive(String destination) |
protected void |
doSend(String destination,
Message<?> message) |
protected void |
doSend(String exchange,
String routingKey,
Message<?> message) |
protected Message<?> |
doSendAndReceive(String destination,
Message<?> requestMessage) |
protected Message<?> |
doSendAndReceive(String exchange,
String routingKey,
Message<?> requestMessage) |
MessageConverter |
getAmqpMessageConverter() |
RabbitTemplate |
getRabbitTemplate() |
void |
send(String exchange,
String routingKey,
Message<?> message)
Send a message to a specific exchange with a specific routing key.
|
Message<?> |
sendAndReceive(String exchange,
String routingKey,
Message<?> requestMessage)
Send a request message to a specific exchange with a specific routing key and
wait for the reply
|
void |
setAmqpMessageConverter(MessageConverter amqpMessageConverter)
|
void |
setRabbitTemplate(RabbitTemplate rabbitTemplate)
Set the
RabbitTemplate to use. |
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive, sendAndReceive
doConvert, receive, receive, receiveAndConvert, receiveAndConvert
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, send
receive, receive, receiveAndConvert, receiveAndConvert
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive, sendAndReceive
public RabbitMessagingTemplate()
setRabbitTemplate(org.springframework.amqp.rabbit.core.RabbitTemplate)
to be called.public RabbitMessagingTemplate(RabbitTemplate rabbitTemplate)
RabbitTemplate
to use.rabbitTemplate
- the template.public void setRabbitTemplate(RabbitTemplate rabbitTemplate)
RabbitTemplate
to use.rabbitTemplate
- the template.public RabbitTemplate getRabbitTemplate()
RabbitTemplate
.public void setAmqpMessageConverter(MessageConverter amqpMessageConverter)
MessageConverter
to use to convert a Message
from
the messaging to and from a Message
.
By default, a MessagingMessageConverter
is defined using the provided
RabbitTemplate
's message converter (a
SimpleMessageConverter
by default) to convert the payload of the message.
Consider configuring a MessagingMessageConverter
with a different
payload converter
for more advanced scenarios.
amqpMessageConverter
- the message converter.MessagingMessageConverter
public MessageConverter getAmqpMessageConverter()
MessageConverter
to use to convert a Message
from the messaging to and from a Message
.public void afterPropertiesSet()
afterPropertiesSet
in interface InitializingBean
public void send(String exchange, String routingKey, Message<?> message) throws MessagingException
RabbitMessageOperations
send
in interface RabbitMessageOperations
exchange
- the name of the exchangeroutingKey
- the routing keymessage
- the message to sendMessagingException
public void convertAndSend(String exchange, String routingKey, Object payload) throws MessagingException
RabbitMessageOperations
MessageConverter
,
wrap it as a message and send it to a specific exchange with a
specific routing key.convertAndSend
in interface RabbitMessageOperations
exchange
- the name of the exchangeroutingKey
- the routing keypayload
- the Object to use as payloadMessagingException
public void convertAndSend(String exchange, String routingKey, Object payload, Map<String,Object> headers) throws MessagingException
RabbitMessageOperations
MessageConverter
,
wrap it as a message with the given headers and send it to a
specific exchange with a specific routing key.convertAndSend
in interface RabbitMessageOperations
exchange
- the name of the exchangeroutingKey
- the routing keypayload
- the Object to use as payloadheaders
- headers for the message to sendMessagingException
public void convertAndSend(String exchange, String routingKey, Object payload, MessagePostProcessor postProcessor) throws MessagingException
RabbitMessageOperations
MessageConverter
,
wrap it as a message, apply the given post processor, and send
the resulting message to a specific exchange with a specific
routing key.convertAndSend
in interface RabbitMessageOperations
exchange
- the name of the exchangeroutingKey
- the routing keypayload
- the Object to use as payloadpostProcessor
- the post processor to apply to the messageMessagingException
public void convertAndSend(String exchange, String routingKey, Object payload, Map<String,Object> headers, MessagePostProcessor postProcessor) throws MessagingException
RabbitMessageOperations
MessageConverter
,
wrap it as a message with the given headers, apply the given post processor,
and send the resulting message to a specific exchange with a specific
routing key.convertAndSend
in interface RabbitMessageOperations
exchange
- the name of the exchangeroutingKey
- the routing keypayload
- the Object to use as payloadheaders
- headers for the message to sendpostProcessor
- the post processor to apply to the messageMessagingException
public Message<?> sendAndReceive(String exchange, String routingKey, Message<?> requestMessage) throws MessagingException
RabbitMessageOperations
sendAndReceive
in interface RabbitMessageOperations
exchange
- the name of the exchangeroutingKey
- the routing keyrequestMessage
- the message to sendnull
if the message could not be received,
for example due to a timeoutMessagingException
public <T> T convertSendAndReceive(String exchange, String routingKey, Object request, Class<T> targetClass) throws MessagingException
RabbitMessageOperations
MessageConverter
, send
it as a Message
to a specific exchange with a specific routing key,
receive the reply and convert its body of the specified target class.convertSendAndReceive
in interface RabbitMessageOperations
T
- return typeexchange
- the name of the exchangeroutingKey
- the routing keyrequest
- payload for the request message to sendtargetClass
- the target type to convert the payload of the reply tonull
if the message
could not be received, for example due to a timeoutMessagingException
public <T> T convertSendAndReceive(String exchange, String routingKey, Object request, Map<String,Object> headers, Class<T> targetClass) throws MessagingException
RabbitMessageOperations
MessageConverter
, send
it as a Message
with the given headers, to a specific exchange
with a specific routing key, receive the reply and convert its body of
the specified target class.convertSendAndReceive
in interface RabbitMessageOperations
T
- return typeexchange
- the name of the exchangeroutingKey
- the routing keyrequest
- payload for the request message to sendheaders
- headers for the request message to sendtargetClass
- the target type to convert the payload of the reply tonull
if the message
could not be received, for example due to a timeoutMessagingException
public <T> T convertSendAndReceive(String exchange, String routingKey, Object request, Class<T> targetClass, MessagePostProcessor requestPostProcessor) throws MessagingException
RabbitMessageOperations
MessageConverter
,
apply the given post processor and send the resulting Message
to
a specific exchange with a specific routing key, receive the reply and
convert its body of the given target class.convertSendAndReceive
in interface RabbitMessageOperations
T
- return typeexchange
- the name of the exchangeroutingKey
- the routing keyrequest
- payload for the request message to sendtargetClass
- the target type to convert the payload of the reply torequestPostProcessor
- post process to apply to the request messagenull
if the message
could not be received, for example due to a timeoutMessagingException
public <T> T convertSendAndReceive(String exchange, String routingKey, Object request, Map<String,Object> headers, Class<T> targetClass, MessagePostProcessor requestPostProcessor) throws MessagingException
RabbitMessageOperations
MessageConverter
,
wrap it as a message with the given headers, apply the given post processor
and send the resulting Message
to a specific exchange with a
specific routing key,, receive the reply and convert its body of the
given target class.convertSendAndReceive
in interface RabbitMessageOperations
T
- return typeexchange
- the name of the exchangeroutingKey
- the routing keyrequest
- payload for the request message to sendheaders
- headers for the message to sendtargetClass
- the target type to convert the payload of the reply torequestPostProcessor
- post process to apply to the request messagenull
if the message
could not be received, for example due to a timeoutMessagingException
protected void doSend(String destination, Message<?> message)
doSend
in class AbstractMessageSendingTemplate<String>
protected Message<?> doReceive(String destination)
doReceive
in class AbstractMessageReceivingTemplate<String>
protected Message<?> doSendAndReceive(String destination, Message<?> requestMessage)
doSendAndReceive
in class AbstractMessagingTemplate<String>
protected Message<?> doSendAndReceive(String exchange, String routingKey, Message<?> requestMessage)
protected MessagingException convertAmqpException(RuntimeException ex)