public interface AMQPMessageConverter
Modifier and Type | Method and Description |
---|---|
AMQPMessage |
createAMQPMessage(EventMessage<?> eventMessage)
Creates an AMQPMessage from given
eventMessage . |
Optional<EventMessage<?>> |
readAMQPMessage(byte[] messageBody,
Map<String,Object> headers)
Reconstruct an EventMessage from the given
messageBody and headers . |
AMQPMessage createAMQPMessage(EventMessage<?> eventMessage)
eventMessage
.eventMessage
- The EventMessage to create the AMQP Message fromOptional<EventMessage<?>> readAMQPMessage(byte[] messageBody, Map<String,Object> headers)
messageBody
and headers
. The returned optional
resolves to a message if the given input parameters represented a correct event message.messageBody
- The body of the AMQP Messageheaders
- The headers attached to the AMQP MessageCopyright © 2010–2017. All rights reserved.