public final class RawMessageDeserializer extends java.lang.Object implements InternalDeserializer<DatabusMessage>
Constructor and Description |
---|
RawMessageDeserializer() |
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. |
public DatabusMessage deserialize(java.lang.String topic, byte[] data)
DatabusMessage
with
this binary data and empty headers.deserialize
in interface InternalDeserializer<DatabusMessage>
topic
- Topic name Not used field.data
- Data to be deserialized.DatabusMessage
with binary data as is.