com.opendxl.databus.common.internal.adapter

Class DatabusMessageAdapter<P>

java.lang.Object

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

Type Parameters:

P - payload's getInstance

All Implemented Interfaces:

Adapter<DatabusMessage,MessagePayload>

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

A Adapter for Databus Message

Constructor Summary

Constructors

Constructor and Description
DatabusMessageAdapter(Deserializer<P> messageDeserializer) Constructor

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabusMessageAdapter

public DatabusMessageAdapter(Deserializer<P> messageDeserializer)

Constructor

Parameters:

messageDeserializer - a Deserializer instance used for deserialize the payload.

Method Detail

adapt

public MessagePayload<P> adapt(DatabusMessage databusMessage)

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

Specified by:

adapt in interface Adapter<DatabusMessage,MessagePayload>

Parameters:

databusMessage - A DatabusMessage instance.

Returns:

A MessagePayload instance.