com.opendxl.databus.serialization.internal

Class RawMessageStructure

java.lang.Object

com.opendxl.databus.serialization.internal.RawMessageStructure

All Implemented Interfaces:

MessageStructure

public final class RawMessageStructure
extends java.lang.Object
implements MessageStructure

Represents a message produced with a non-SDK producer, for getInstance Kafka SDK.

Constructor Summary

Constructors

Constructor and Description
RawMessageStructure(byte[] serializedMessage) The Constructor.

Method Summary

Modifier and Type	Method and Description
byte	getMagicByte() Gets the magic byte.
byte[]	getMessage() Gets the message.
byte[]	getPayload() Gets the payload.
int	getVersion() Gets the version.

Methods inherited from class java.lang.Object

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

Constructor Detail

RawMessageStructure

public RawMessageStructure(byte[] serializedMessage)

The Constructor.

Parameters:

serializedMessage - A serialized message.

Method Detail

getMagicByte

public byte getMagicByte()

Gets the magic byte.

Specified by:

getMagicByte in interface MessageStructure

Returns:

The magic byte.

getVersion

public int getVersion()

Gets the version.

Specified by:

getVersion in interface MessageStructure

Returns:

The version.

getPayload

public byte[] getPayload()

Gets the payload.

Specified by:

getPayload in interface MessageStructure

Returns:

The payload.

getMessage

public byte[] getMessage()

Gets the message.

Specified by:

getMessage in interface MessageStructure

Returns:

The message.