pulsar-client-cpp
Loading...
Searching...
No Matches
BatchReceivePolicy.h
1
19#ifndef BATCH_RECEIVE_POLICY_HPP_
20#define BATCH_RECEIVE_POLICY_HPP_
21
22#include <pulsar/defines.h>
23
24#include <memory>
25
26namespace pulsar {
27
28struct BatchReceivePolicyImpl;
29
52class PULSAR_PUBLIC BatchReceivePolicy {
53 public:
58
66 BatchReceivePolicy(int maxNumMessage, long maxNumBytes, long timeoutMs);
67
73 long getTimeoutMs() const;
74
79 int getMaxNumMessages() const;
80
85 long getMaxNumBytes() const;
86
87 private:
88 std::shared_ptr<BatchReceivePolicyImpl> impl_;
89};
90} // namespace pulsar
91
92#endif /* BATCH_RECEIVE_POLICY_HPP_ */
Definition BatchReceivePolicy.h:52
BatchReceivePolicy(int maxNumMessage, long maxNumBytes, long timeoutMs)
Definition Authentication.h:31