P
- payload's typepublic final class MessagePayloadAdapter<P> extends java.lang.Object implements Adapter<MessagePayload<P>,DatabusMessage>
Constructor and Description |
---|
MessagePayloadAdapter(Serializer<P> messageSerializer,
Headers headers)
Constructor
|
Modifier and Type | Method and Description |
---|---|
DatabusMessage |
adapt(MessagePayload<P> messagePayload)
Adapter pattern implementation for DatabusMessage instance.
|
public MessagePayloadAdapter(Serializer<P> messageSerializer, Headers headers)
messageSerializer
- A Serializer
instance
or creating a DatabusMessage
.headers
- Headers map.public DatabusMessage adapt(MessagePayload<P> messagePayload)
adapt
in interface Adapter<MessagePayload<P>,DatabusMessage>
messagePayload
- a MessagePayload
instance to be adapted.DatabusMessage
instance.