#include <MessageIdBuilder.h>

Public Member Functions
MessageId	build () const

MessageIdBuilder &	ledgerId (int64_t ledgerId)

MessageIdBuilder &	entryId (int64_t entryId)

MessageIdBuilder &	partition (int32_t partition)

MessageIdBuilder &	batchIndex (int32_t batchIndex)

MessageIdBuilder &	batchSize (int32_t batchSize)

Static Public Member Functions
static MessageIdBuilder	from (const MessageId &messageId)

static MessageIdBuilder	from (const proto::MessageIdData &messageIdData)

Detailed Description

The builder to build a MessageId.

Example of building a single MessageId:

 {c++}
MessageId msgId = MessageIdBuilder()
                      .ledgerId(0L)
                      .entryId(0L)
                      .build();

Example of building a batched MessageId:

 {c++}
MessageId msgId = MessageIdBuilder()
                      .ledgerId(0L)
                      .entryId(0L)
                      .batchIndex(0)
                      .batchSize(2)
                      .build();

Member Function Documentation

◆ batchIndex()

MessageIdBuilder& pulsar::MessageIdBuilder::batchIndex ( int32_t batchIndex )

Set the batch index.

Default: -1

◆ batchSize()

MessageIdBuilder& pulsar::MessageIdBuilder::batchSize ( int32_t batchSize )

Set the batch size.

Default: 0

◆ build()

MessageId pulsar::MessageIdBuilder::build ( ) const

Build a MessageId.

◆ entryId()

MessageIdBuilder& pulsar::MessageIdBuilder::entryId ( int64_t entryId )

Set the entry ID field.

Default: -1L

◆ from() [1/2]

static MessageIdBuilder pulsar::MessageIdBuilder::from ( const MessageId & messageId )

static

Create an instance that copies the data from messageId.

◆ from() [2/2]

static MessageIdBuilder pulsar::MessageIdBuilder::from ( const proto::MessageIdData & messageIdData )

static

Create an instance from the proto::MessageIdData instance.

Note: It's an internal API that converts the MessageIdData defined by PulsarApi.proto

See also: https://github.com/apache/pulsar-client-cpp/blob/main/proto/PulsarApi.proto

◆ ledgerId()

MessageIdBuilder& pulsar::MessageIdBuilder::ledgerId ( int64_t ledgerId )

Set the ledger ID field.

Default: -1L

◆ partition()

MessageIdBuilder& pulsar::MessageIdBuilder::partition ( int32_t partition )

Set the partition index.