com.opendxl.databus.serialization.internal

Class LegacyMessageDeserializer

java.lang.Object

com.opendxl.databus.serialization.internal.LegacyMessageDeserializer

All Implemented Interfaces:

InternalDeserializer<DatabusMessage>

public final class LegacyMessageDeserializer
extends java.lang.Object
implements InternalDeserializer<DatabusMessage>

Deserilize Legacy JSON messages

For example: {"headers":{"sourceId":"abc","tenantId":"TENANT10"}, "payloadBase64String":"wqFIb2xhISBIdWdvIGFxdcOtLg=="}*

Constructor Summary

Constructors

Constructor and Description
LegacyMessageDeserializer()

Method Summary

Modifier and Type	Method and Description
DatabusMessage	deserialize(java.lang.String topic, byte[] data) Deserialize data to a DatabusMessage.

Methods inherited from class java.lang.Object

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

Constructor Detail

LegacyMessageDeserializer

public LegacyMessageDeserializer()

Method Detail

deserialize

public DatabusMessage deserialize(java.lang.String topic,
                                  byte[] data)

Deserialize data to a DatabusMessage.

Specified by:

deserialize in interface InternalDeserializer<DatabusMessage>

Parameters:

data - Data to be deserialized.

topic - the topic where the message comes from

Returns:

A DatabusMessage instance.