Class EventBusMessageDecoder

java.lang.Object

com.iohao.net.sbe.EventBusMessageDecoder

public final class EventBusMessageDecoder
extends Object

EventBusMessage

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BLOCK_LENGTH
static final ByteOrder	BYTE_ORDER
static final int	SCHEMA_ID
static final int	SCHEMA_VERSION
static final String	SEMANTIC_VERSION
static final int	TEMPLATE_ID

Constructor Summary

Constructors

Constructor	Description
EventBusMessageDecoder()

Method Summary

Modifier and Type	Method	Description
int	actingVersion()
StringBuilder	appendTo(StringBuilder builder)
org.agrona.DirectBuffer	buffer()
static int	dataHeaderLength()
static int	dataId()
int	dataLength()
static String	dataMetaAttribute(MetaAttribute metaAttribute)
static int	dataSinceVersion()
int	encodedLength()
int	getData(byte[] dst, int dstOffset, int length)
int	getData(org.agrona.MutableDirectBuffer dst, int dstOffset, int length)
int	getTopic(byte[] dst, int dstOffset, int length)
int	getTopic(org.agrona.MutableDirectBuffer dst, int dstOffset, int length)
int	getTraceId(byte[] dst, int dstOffset)
int	getTraceId(Appendable value)
int	limit()
void	limit(int limit)
int	offset()
int	sbeBlockLength()
int	sbeDecodedLength()
EventBusMessageDecoder	sbeRewind()
int	sbeSchemaId()
int	sbeSchemaVersion()
String	sbeSemanticType()
EventBusMessageDecoder	sbeSkip()
int	sbeTemplateId()
int	serverId()
static int	serverIdEncodingLength()
static int	serverIdEncodingOffset()
static int	serverIdId()
static int	serverIdMaxValue()
static String	serverIdMetaAttribute(MetaAttribute metaAttribute)
static int	serverIdMinValue()
static int	serverIdNullValue()
static int	serverIdSinceVersion()
int	skipData()
int	skipTopic()
long	threadIndex()
static int	threadIndexEncodingLength()
static int	threadIndexEncodingOffset()
static int	threadIndexId()
static long	threadIndexMaxValue()
static String	threadIndexMetaAttribute(MetaAttribute metaAttribute)
static long	threadIndexMinValue()
static long	threadIndexNullValue()
static int	threadIndexSinceVersion()
String	topic()
static String	topicCharacterEncoding()
static int	topicHeaderLength()
static int	topicId()
int	topicLength()
static String	topicMetaAttribute(MetaAttribute metaAttribute)
static int	topicSinceVersion()
String	toString()
String	traceId()
byte	traceId(int index)
static String	traceIdCharacterEncoding()
static int	traceIdEncodingLength()
static int	traceIdEncodingOffset()
static int	traceIdId()
static int	traceIdLength()
static byte	traceIdMaxValue()
static String	traceIdMetaAttribute(MetaAttribute metaAttribute)
static byte	traceIdMinValue()
static byte	traceIdNullValue()
static int	traceIdSinceVersion()
EventBusMessageDecoder	wrap(org.agrona.DirectBuffer buffer, int offset, int actingBlockLength, int actingVersion)
EventBusMessageDecoder	wrapAndApplyHeader(org.agrona.DirectBuffer buffer, int offset, MessageHeaderDecoder headerDecoder)
void	wrapData(org.agrona.DirectBuffer wrapBuffer)
void	wrapTopic(org.agrona.DirectBuffer wrapBuffer)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

BLOCK_LENGTH

public static final int BLOCK_LENGTH

See Also:

• Constant Field Values

TEMPLATE_ID

public static final int TEMPLATE_ID

See Also:

• Constant Field Values

SCHEMA_ID

public static final int SCHEMA_ID

See Also:

• Constant Field Values

SCHEMA_VERSION

public static final int SCHEMA_VERSION

See Also:

• Constant Field Values

SEMANTIC_VERSION

public static final String SEMANTIC_VERSION

See Also:

• Constant Field Values

BYTE_ORDER

public static final ByteOrder BYTE_ORDER

Constructor Details

EventBusMessageDecoder

public EventBusMessageDecoder()

Method Details

sbeBlockLength

public int sbeBlockLength()

sbeTemplateId

public int sbeTemplateId()

sbeSchemaId

public int sbeSchemaId()

sbeSchemaVersion

public int sbeSchemaVersion()

sbeSemanticType

public String sbeSemanticType()

buffer

public org.agrona.DirectBuffer buffer()

offset

public int offset()

wrap

public EventBusMessageDecoder wrap(org.agrona.DirectBuffer buffer,
 int offset,
 int actingBlockLength,
 int actingVersion)

wrapAndApplyHeader

public EventBusMessageDecoder wrapAndApplyHeader(org.agrona.DirectBuffer buffer,
 int offset,
 MessageHeaderDecoder headerDecoder)

sbeRewind

public EventBusMessageDecoder sbeRewind()

sbeDecodedLength

public int sbeDecodedLength()

actingVersion

public int actingVersion()

encodedLength

public int encodedLength()

limit

public int limit()

limit

public void limit(int limit)

serverIdId

public static int serverIdId()

serverIdSinceVersion

public static int serverIdSinceVersion()

serverIdEncodingOffset

public static int serverIdEncodingOffset()

serverIdEncodingLength

public static int serverIdEncodingLength()

serverIdMetaAttribute

public static String serverIdMetaAttribute(MetaAttribute metaAttribute)

serverIdNullValue

public static int serverIdNullValue()

serverIdMinValue

public static int serverIdMinValue()

serverIdMaxValue

public static int serverIdMaxValue()

serverId

public int serverId()

threadIndexId

public static int threadIndexId()

threadIndexSinceVersion

public static int threadIndexSinceVersion()

threadIndexEncodingOffset

public static int threadIndexEncodingOffset()

threadIndexEncodingLength

public static int threadIndexEncodingLength()

threadIndexMetaAttribute

public static String threadIndexMetaAttribute(MetaAttribute metaAttribute)

threadIndexNullValue

public static long threadIndexNullValue()

threadIndexMinValue

public static long threadIndexMinValue()

threadIndexMaxValue

public static long threadIndexMaxValue()

threadIndex

public long threadIndex()

traceIdId

public static int traceIdId()

traceIdSinceVersion

public static int traceIdSinceVersion()

traceIdEncodingOffset

public static int traceIdEncodingOffset()

traceIdEncodingLength

public static int traceIdEncodingLength()

traceIdMetaAttribute

public static String traceIdMetaAttribute(MetaAttribute metaAttribute)

traceIdNullValue

public static byte traceIdNullValue()

traceIdMinValue

public static byte traceIdMinValue()

traceIdMaxValue

public static byte traceIdMaxValue()

traceIdLength

public static int traceIdLength()

traceId

public byte traceId(int index)

traceIdCharacterEncoding

public static String traceIdCharacterEncoding()

getTraceId

public int getTraceId(byte[] dst,
 int dstOffset)

traceId

public String traceId()

getTraceId

public int getTraceId(Appendable value)

topicId

public static int topicId()

topicSinceVersion

public static int topicSinceVersion()

topicCharacterEncoding

public static String topicCharacterEncoding()

topicMetaAttribute

public static String topicMetaAttribute(MetaAttribute metaAttribute)

topicHeaderLength

public static int topicHeaderLength()

topicLength

public int topicLength()

skipTopic

public int skipTopic()

getTopic

public int getTopic(org.agrona.MutableDirectBuffer dst,
 int dstOffset,
 int length)

getTopic

public int getTopic(byte[] dst,
 int dstOffset,
 int length)

wrapTopic

public void wrapTopic(org.agrona.DirectBuffer wrapBuffer)

topic

public String topic()

dataId

public static int dataId()

dataSinceVersion

public static int dataSinceVersion()

dataMetaAttribute

public static String dataMetaAttribute(MetaAttribute metaAttribute)

dataHeaderLength

public static int dataHeaderLength()

dataLength

public int dataLength()

skipData

public int skipData()

getData

public int getData(org.agrona.MutableDirectBuffer dst,
 int dstOffset,
 int length)

getData

public int getData(byte[] dst,
 int dstOffset,
 int length)

wrapData

public void wrapData(org.agrona.DirectBuffer wrapBuffer)

toString

public String toString()

Overrides:

toString in class Object

appendTo

public StringBuilder appendTo(StringBuilder builder)

sbeSkip

public EventBusMessageDecoder sbeSkip()