begin transaction message is only used for transaction, once a begin transaction message is received, all messages combined with the transaction message cannot be consumed until a CommitTxn message is received.

commit transaction message is only used for transaction, once a commit transaction message is received, all messages combined with the transaction message can be consumed, the message combined with the transaction which is received after the commit transaction message will be drop.

rollback transaction message is only used for transaction, once a rollback transaction message is received, all messages combined with the transaction message can be discarded, the message combined with the transaction which is received after the rollback transaction message will be drop.

txn message is a set of messages combined by multiple messages in a transaction.

the domain of collection name.

the domain of import job id.

should never be used.

the transaction begin.

the transaction is committed.

the transaction is in flight.

the transaction is on commit.

the transaction is on rollback.

the transaction is rollbacked.

should never be used.

Enum value maps for MessageType.

Enum value maps for MessageType.

Enum value maps for ResourceDomain.

Enum value maps for ResourceDomain.

Enum value maps for TxnState.

Enum value maps for TxnState.

BeginTxnMessageBody is the body of begin transaction message.

BeginTxnMessageHeader is the header of begin transaction message.

BroadcastHeader is the common header of broadcast message.

CommitTxnMessageBody is the body of commit transaction message.

CommitTxnMessageHeader is the header of commit transaction message.

CreateCollectionMessageHeader is the header of create collection message.

CreatePartitionMessageHeader is the header of create partition message.

CreateSegmentInfo is the info of create segment.

CreateSegmentMessageBody is the body of create segment message.

CreateSegmentMessageHeader just nothing.

DeleteMessageHeader.

DropCollectionMessageHeader is the header of drop collection message.

DropPartitionMessageHeader is the header of drop partition message.

FlushMessageBody is the body of flush message.

FlushMessageHeader just nothing.

ImmutableMessage is the message that can not be modified anymore.

InsertMessageHeader is the header of insert message.

ManualFlushExtraResponse is the extra response of manual flush message.

ManualFlushMessageBody is the body of manual flush message.

Message is the basic unit of communication between publisher and consumer.

MessageID is the unique identifier of a message.

PartitionSegmentAssignment is the segment assignment of a partition.

ResourceKey is the key for resource hold.

RMQMessageLayout is the layout of message for RMQ.

RollbackTxnMessageBody is the body of rollback transaction message.

RollbackTxnMessageHeader is the header of rollback transaction message.

SegmentAssignment is the assignment of a segment.

TimeTickMessageHeader just nothing.

TxnContext is the context of transaction.

TxnMessageBody is the body of transaction message.

TxnMessageHeader is the header of transaction message.

MessageType is the type of message.

ResourceDomain is the domain of resource hold.