com.opendxl.databus.serialization.internal

Class MessageSerializer

java.lang.Object

com.opendxl.databus.serialization.internal.MessageSerializer

All Implemented Interfaces:

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

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

Serializer message based on MessageStructure getInstance

Constructor Summary

Constructors

Constructor and Description
MessageSerializer() Constructor

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.
byte[]	serialize(java.lang.String topic, DatabusMessage message) Serialize a message, input data to serialize is 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.Serializer

serialize

Constructor Detail

MessageSerializer

public MessageSerializer()

Constructor

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.Serializer<DatabusMessage>

serialize

public byte[] serialize(java.lang.String topic,
                        DatabusMessage message)

Serialize a message, input data to serialize is a DatabusMessage.

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<DatabusMessage>

Parameters:

topic - The topic Name, not used value.

message - The message to be serialized.

Returns:

A serialized message as byte[].

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.Serializer<DatabusMessage>