Class BroadcastUserMessageDecoder
java.lang.Object
com.iohao.net.sbe.BroadcastUserMessageDecoder
BroadcastUserMessage
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintappendTo(StringBuilder builder) org.agrona.DirectBufferbuffer()intcmdMerge()static intstatic intstatic intstatic intstatic StringcmdMergeMetaAttribute(MetaAttribute metaAttribute) static intstatic intstatic intstatic intstatic intdataId()intstatic StringdataMetaAttribute(MetaAttribute metaAttribute) static intintshortstatic intstatic intstatic intstatic shortstatic StringerrorCodeMetaAttribute(MetaAttribute metaAttribute) static shortstatic shortstatic intstatic Stringstatic intstatic intintstatic StringerrorMessageMetaAttribute(MetaAttribute metaAttribute) static intintstatic intstatic intstatic intstatic intstatic StringexternalServerIdMetaAttribute(MetaAttribute metaAttribute) static intstatic intstatic intintgetData(byte[] dst, int dstOffset, int length) intgetData(org.agrona.MutableDirectBuffer dst, int dstOffset, int length) intgetErrorMessage(byte[] dst, int dstOffset, int length) intgetErrorMessage(org.agrona.MutableDirectBuffer dst, int dstOffset, int length) intlimit()voidlimit(int limit) intstatic intstatic intstatic intstatic intstatic StringlogicServerIdMetaAttribute(MetaAttribute metaAttribute) static intstatic intstatic intintoffset()intintintintsbeSkip()intintskipData()inttoString()static intstatic intstatic intstatic StringuserIdentityMetaAttribute(MetaAttribute metaAttribute) static intwrap(org.agrona.DirectBuffer buffer, int offset, int actingBlockLength, int actingVersion) wrapAndApplyHeader(org.agrona.DirectBuffer buffer, int offset, MessageHeaderDecoder headerDecoder) voidwrapData(org.agrona.DirectBuffer wrapBuffer) voidwrapErrorMessage(org.agrona.DirectBuffer wrapBuffer)
-
Field Details
-
BLOCK_LENGTH
public static final int BLOCK_LENGTH- See Also:
-
TEMPLATE_ID
public static final int TEMPLATE_ID- See Also:
-
SCHEMA_ID
public static final int SCHEMA_ID- See Also:
-
SCHEMA_VERSION
public static final int SCHEMA_VERSION- See Also:
-
SEMANTIC_VERSION
- See Also:
-
BYTE_ORDER
-
-
Constructor Details
-
BroadcastUserMessageDecoder
public BroadcastUserMessageDecoder()
-
-
Method Details
-
sbeBlockLength
public int sbeBlockLength() -
sbeTemplateId
public int sbeTemplateId() -
sbeSchemaId
public int sbeSchemaId() -
sbeSchemaVersion
public int sbeSchemaVersion() -
sbeSemanticType
-
buffer
public org.agrona.DirectBuffer buffer() -
offset
public int offset() -
wrap
public BroadcastUserMessageDecoder wrap(org.agrona.DirectBuffer buffer, int offset, int actingBlockLength, int actingVersion) -
wrapAndApplyHeader
public BroadcastUserMessageDecoder wrapAndApplyHeader(org.agrona.DirectBuffer buffer, int offset, MessageHeaderDecoder headerDecoder) -
sbeRewind
-
sbeDecodedLength
public int sbeDecodedLength() -
actingVersion
public int actingVersion() -
encodedLength
public int encodedLength() -
limit
public int limit() -
limit
public void limit(int limit) -
cmdMergeId
public static int cmdMergeId() -
cmdMergeSinceVersion
public static int cmdMergeSinceVersion() -
cmdMergeEncodingOffset
public static int cmdMergeEncodingOffset() -
cmdMergeEncodingLength
public static int cmdMergeEncodingLength() -
cmdMergeMetaAttribute
-
cmdMergeNullValue
public static int cmdMergeNullValue() -
cmdMergeMinValue
public static int cmdMergeMinValue() -
cmdMergeMaxValue
public static int cmdMergeMaxValue() -
cmdMerge
public int cmdMerge() -
userIdentityId
public static int userIdentityId() -
userIdentitySinceVersion
public static int userIdentitySinceVersion() -
userIdentityEncodingOffset
public static int userIdentityEncodingOffset() -
userIdentityEncodingLength
public static int userIdentityEncodingLength() -
userIdentityMetaAttribute
-
userIdentity
-
logicServerIdId
public static int logicServerIdId() -
logicServerIdSinceVersion
public static int logicServerIdSinceVersion() -
logicServerIdEncodingOffset
public static int logicServerIdEncodingOffset() -
logicServerIdEncodingLength
public static int logicServerIdEncodingLength() -
logicServerIdMetaAttribute
-
logicServerIdNullValue
public static int logicServerIdNullValue() -
logicServerIdMinValue
public static int logicServerIdMinValue() -
logicServerIdMaxValue
public static int logicServerIdMaxValue() -
logicServerId
public int logicServerId() -
externalServerIdId
public static int externalServerIdId() -
externalServerIdSinceVersion
public static int externalServerIdSinceVersion() -
externalServerIdEncodingOffset
public static int externalServerIdEncodingOffset() -
externalServerIdEncodingLength
public static int externalServerIdEncodingLength() -
externalServerIdMetaAttribute
-
externalServerIdNullValue
public static int externalServerIdNullValue() -
externalServerIdMinValue
public static int externalServerIdMinValue() -
externalServerIdMaxValue
public static int externalServerIdMaxValue() -
externalServerId
public int externalServerId() -
errorCodeId
public static int errorCodeId() -
errorCodeSinceVersion
public static int errorCodeSinceVersion() -
errorCodeEncodingOffset
public static int errorCodeEncodingOffset() -
errorCodeEncodingLength
public static int errorCodeEncodingLength() -
errorCodeMetaAttribute
-
errorCodeNullValue
public static short errorCodeNullValue() -
errorCodeMinValue
public static short errorCodeMinValue() -
errorCodeMaxValue
public static short errorCodeMaxValue() -
errorCode
public short errorCode() -
errorMessageId
public static int errorMessageId() -
errorMessageSinceVersion
public static int errorMessageSinceVersion() -
errorMessageCharacterEncoding
-
errorMessageMetaAttribute
-
errorMessageHeaderLength
public static int errorMessageHeaderLength() -
errorMessageLength
public int errorMessageLength() -
skipErrorMessage
public int skipErrorMessage() -
getErrorMessage
public int getErrorMessage(org.agrona.MutableDirectBuffer dst, int dstOffset, int length) -
getErrorMessage
public int getErrorMessage(byte[] dst, int dstOffset, int length) -
wrapErrorMessage
public void wrapErrorMessage(org.agrona.DirectBuffer wrapBuffer) -
errorMessage
-
dataId
public static int dataId() -
dataSinceVersion
public static int dataSinceVersion() -
dataMetaAttribute
-
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
-
appendTo
-
sbeSkip
-