19 #ifndef LIB_BATCHMESSAGEID_H_ 20 #define LIB_BATCHMESSAGEID_H_ 22 #include <pulsar/MessageId.h> 23 #pragma GCC visibility push(default) 28 BatchMessageId(int64_t ledgerId, int64_t entryId,
int batchIndex = -1)
30 batchIndex_(batchIndex) {
40 friend class ConsumerImpl;
42 friend class MessageImpl;
43 friend class PartitionedProducerImpl;
44 friend class PartitionedConsumerImpl;
45 friend class BatchAcknowledgementTracker;
46 friend class PulsarWrapper;
47 friend class PulsarFriend;
52 return (ledgerId_ < mID.ledgerId_) || (ledgerId_ == mID.ledgerId_ && entryId_ < mID.entryId_);
55 bool BatchMessageId::operator<=(
const BatchMessageId& mID)
const {
56 return (ledgerId_ < mID.ledgerId_) || (ledgerId_ == mID.ledgerId_ && entryId_ <= mID.entryId_);
60 #pragma GCC visibility pop Definition: Authentication.h:31
Definition: BatchMessageId.h:26
Definition: MessageId.h:33