Class EventBusMessageEncoder

java.lang.Object
com.iohao.net.sbe.EventBusMessageEncoder
public final class EventBusMessageEncoder extends Object
EventBusMessage

  • Field Details

  • Constructor Details

    • EventBusMessageEncoder

      public EventBusMessageEncoder()

  • 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.MutableDirectBuffer buffer()

    • offset

      public int offset()

    • wrap

      public EventBusMessageEncoder wrap(org.agrona.MutableDirectBuffer buffer, int offset)

    • wrapAndApplyHeader

      public EventBusMessageEncoder wrapAndApplyHeader(org.agrona.MutableDirectBuffer buffer, int offset, MessageHeaderEncoder headerEncoder)

    • 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 EventBusMessageEncoder serverId(int value)

    • 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 EventBusMessageEncoder threadIndex(long value)

    • 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 EventBusMessageEncoder traceId(int index, byte value)

    • traceIdCharacterEncoding

      public static String traceIdCharacterEncoding()

    • putTraceId

      public EventBusMessageEncoder putTraceId(byte[] src, int srcOffset)

    • traceId

      public EventBusMessageEncoder traceId(String src)

    • traceId

      public EventBusMessageEncoder traceId(CharSequence src)

    • topicId

      public static int topicId()

    • topicCharacterEncoding

      public static String topicCharacterEncoding()

    • topicMetaAttribute

      public static String topicMetaAttribute(MetaAttribute metaAttribute)

    • topicHeaderLength

      public static int topicHeaderLength()

    • putTopic

      public EventBusMessageEncoder putTopic(org.agrona.DirectBuffer src, int srcOffset, int length)

    • putTopic

      public EventBusMessageEncoder putTopic(byte[] src, int srcOffset, int length)

    • topic

      public EventBusMessageEncoder topic(String value)

    • dataId

      public static int dataId()

    • dataMetaAttribute

      public static String dataMetaAttribute(MetaAttribute metaAttribute)

    • dataHeaderLength

      public static int dataHeaderLength()

    • putData

      public EventBusMessageEncoder putData(org.agrona.DirectBuffer src, int srcOffset, int length)

    • putData

      public EventBusMessageEncoder putData(byte[] src, int srcOffset, int length)

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • appendTo

      public StringBuilder appendTo(StringBuilder builder)