BatchReceivePolicy.h

 
#ifndef BATCH_RECEIVE_POLICY_HPP_
#define BATCH_RECEIVE_POLICY_HPP_
 
#include <pulsar/defines.h>
#include <memory>
 
namespace pulsar {
 
struct BatchReceivePolicyImpl;
 
class PULSAR_PUBLIC BatchReceivePolicy {
   public:
    BatchReceivePolicy();
 
    BatchReceivePolicy(int maxNumMessage, long maxNumBytes, long timeoutMs);
 
    long getTimeoutMs() const;
 
    int getMaxNumMessages() const;
 
    long getMaxNumBytes() const;
 
   private:
    std::shared_ptr<BatchReceivePolicyImpl> impl_;
};
}  // namespace pulsar
 
#endif /* BATCH_RECEIVE_POLICY_HPP_ */