base/ru.sydis.base.types.kafka/ProtoMessageWrapper

ProtoMessageWrapper

class ProtoMessageWrapper

Constructors

ProtoMessageWrapper

constructor(iProtoMessage: ProtoMessageOrBuilder)

constructor(ba: ByteArray)

constructor()

Properties

var messageId: ByteString

var msgNum: Long

val protoMessage: ProtoMessage.Builder

val valueDataCount: Int

Functions

fun addAllData(data: List<Message.Builder>): ProtoMessageWrapper

fun addData(data: Message.Builder): ProtoMessageWrapper

fun addData(dpid: ProtoDpId, data: ProtoValue.Builder): ProtoMessageWrapper

fun asBuilder(): ProtoMessage.Builder

fun build(): ProtoMessage

fun clearData()

fun getAllMessages(): List<Message.Builder>

getAllServiceMessages

fun getAllServiceMessages(): List<Message.Builder>

getAllValueMessages

fun getAllValueMessages(): List<ProtoValue.Builder>

fun getCmd(): ProtoCmdType

fun getErrorText(): String

fun getSource(): ProtoManId

fun getStatus(): ProtoErrorCode

fun getToken(): String

fun setCmd(cmd: ProtoCmdType): ProtoMessageWrapper

fun setErrorText(msg: MessageOrBuilder): ProtoMessageWrapper

fun setErrorText(text: String): ProtoMessageWrapper

fun setMessageId(msgId: ByteString): ProtoMessageWrapper

fun setMsgNum(num: Long): ProtoMessageWrapper

fun setSource(src: ProtoManId): ProtoMessageWrapper

fun setStatus(status: ProtoErrorCode): ProtoMessageWrapper

fun setToken(token: String): ProtoMessageWrapper