|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.axonframework.eventhandling.amqp.DefaultAMQPMessageConverter
public class DefaultAMQPMessageConverter
Default implementation of the AMQPMessageConverter interface. This implementation will suffice in most cases, unless very specific requirements exist about the content of an AMQP Message's body. For example with using the Message Broker to interact with non-Axon based applications.
Constructor Summary | |
---|---|
DefaultAMQPMessageConverter(Serializer serializer)
Initializes the AMQPMessageConverter with the given serializer , using a PackageRoutingKeyResolver and requesting durable dispatching. |
|
DefaultAMQPMessageConverter(Serializer serializer,
RoutingKeyResolver routingKeyResolver,
boolean durable)
Initializes the AMQPMessageConverter with the given serializer , routingKeyResolver and
requesting durable dispatching when durable is true . |
Method Summary | |
---|---|
AMQPMessage |
createAMQPMessage(EventMessage eventMessage)
Creates an AMQPMessage from given eventMessage . |
EventMessage |
readAMQPMessage(byte[] messageBody,
Map<String,Object> headers)
Reconstruct an EventMessage from the given messageBody and headers . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DefaultAMQPMessageConverter(Serializer serializer)
serializer
, using a PackageRoutingKeyResolver
and requesting durable dispatching.
serializer
- The serializer to serialize the Event Message's payload and Meta Data withpublic DefaultAMQPMessageConverter(Serializer serializer, RoutingKeyResolver routingKeyResolver, boolean durable)
serializer
, routingKeyResolver
and
requesting durable dispatching when durable
is true
.
serializer
- The serializer to serialize the Event Message's payload and Meta Data withroutingKeyResolver
- The strategy to use to resolve routing keys for Event Messagesdurable
- Whether to request durable message dispatchingMethod Detail |
---|
public AMQPMessage createAMQPMessage(EventMessage eventMessage)
AMQPMessageConverter
eventMessage
.
createAMQPMessage
in interface AMQPMessageConverter
eventMessage
- The EventMessage to create the AMQP Message from
public EventMessage readAMQPMessage(byte[] messageBody, Map<String,Object> headers)
AMQPMessageConverter
messageBody
and headers
.
readAMQPMessage
in interface AMQPMessageConverter
messageBody
- The body of the AMQP Messageheaders
- The headers attached to the AMQP Message
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |