com.opendxl.databus.serialization.internal

Class RawMessageDeserializer

java.lang.Object

com.opendxl.databus.serialization.internal.RawMessageDeserializer

All Implemented Interfaces:

InternalDeserializer<DatabusMessage>

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

Deserialize messages produced by Kafka Client.

Constructor Summary

Constructors

Constructor and Description
RawMessageDeserializer()

Method Summary

Modifier and Type	Method and Description
DatabusMessage	deserialize(java.lang.String topic, byte[] data) It takes binary data from Databus and create a DatabusMessage with this binary data and empty headers.

Methods inherited from class java.lang.Object

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

Constructor Detail

RawMessageDeserializer

public RawMessageDeserializer()

Method Detail

deserialize

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

It takes binary data from Databus and create a DatabusMessage with this binary data and empty headers.

Specified by:

deserialize in interface InternalDeserializer<DatabusMessage>

Parameters:

topic - Topic name Not used field.

data - Data to be deserialized.

Returns:

A DatabusMessage with binary data as is.