MessageBatch.h

 
#ifndef LIB_MESSAGE_BATCH_H
#define LIB_MESSAGE_BATCH_H
#include <pulsar/Message.h>
#include <pulsar/defines.h>
 
#include <vector>
 
namespace pulsar {
 
class PULSAR_PUBLIC MessageBatch {
   public:
    MessageBatch();
 
    MessageBatch& withMessageId(const MessageId& messageId);
 
    MessageBatch& parseFrom(const std::string& payload, uint32_t batchSize);
 
    MessageBatch& parseFrom(const SharedBuffer& payload, uint32_t batchSize);
 
    const std::vector<Message>& messages();
 
   private:
    typedef std::shared_ptr<MessageImpl> MessageImplPtr;
    MessageImplPtr impl_;
    Message batchMessage_;
 
    std::vector<Message> batch_;
};
}  // namespace pulsar
#endif  // LIB_MESSAGE_BATCH_H