com.opendxl.databus.common.internal.adapter

Class MessagePayloadAdapter<P>

java.lang.Object

com.opendxl.databus.common.internal.adapter.MessagePayloadAdapter<P>

Type Parameters:

P - payload's type

All Implemented Interfaces:

Adapter<MessagePayload<P>,DatabusMessage>

public final class MessagePayloadAdapter<P>
extends java.lang.Object
implements Adapter<MessagePayload<P>,DatabusMessage>

Adapter for Message Payload

Constructor Summary

Constructors

Constructor and Description
MessagePayloadAdapter(Serializer<P> messageSerializer, Headers headers) Constructor

Method Summary

Modifier and Type	Method and Description
DatabusMessage	adapt(MessagePayload<P> messagePayload) Adapter pattern implementation for DatabusMessage instance.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessagePayloadAdapter

public MessagePayloadAdapter(Serializer<P> messageSerializer,
                             Headers headers)

Constructor

Parameters:

messageSerializer - A Serializer instance or creating a DatabusMessage.

headers - Headers map.

Method Detail

adapt

public DatabusMessage adapt(MessagePayload<P> messagePayload)

Adapter pattern implementation for DatabusMessage instance. Adapts a MessagePayload to a DatabusMessage instance.

Specified by:

adapt in interface Adapter<MessagePayload<P>,DatabusMessage>

Parameters:

messagePayload - a MessagePayload instance to be adapted.

Returns:

a DatabusMessage instance.