com.opendxl.databus.serialization.internal

Class MessageDeserializer

java.lang.Object

com.opendxl.databus.serialization.internal.MessageDeserializer

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Deserializer<DatabusMessage>

public final class MessageDeserializer
extends java.lang.Object
implements org.apache.kafka.common.serialization.Deserializer<DatabusMessage>

Deserialize a message based on MessageStructure getInstance

Constructor Summary

Constructors

Constructor and Description
MessageDeserializer()

Method Summary

Modifier and Type	Method and Description
void	close() Not implemented.
void	configure(java.util.Map<java.lang.String,?> map, boolean b) Not implemented.
DatabusMessage	deserialize(java.lang.String topic, byte[] serializedMessage) Deserialize a message to a DatabusMessage

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

deserialize

Constructor Detail

MessageDeserializer

public MessageDeserializer()

Method Detail

configure

public void configure(java.util.Map<java.lang.String,?> map,
                      boolean b)

Not implemented.

Specified by:

configure in interface org.apache.kafka.common.serialization.Deserializer<DatabusMessage>

deserialize

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

Deserialize a message to a DatabusMessage

Specified by:

deserialize in interface org.apache.kafka.common.serialization.Deserializer<DatabusMessage>

Parameters:

topic - The topic name.

serializedMessage - A serialized message.

Returns:

A DatabusMessage instance.

close

public void close()

Not implemented.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface org.apache.kafka.common.serialization.Deserializer<DatabusMessage>