pulsar-client-cpp
ConsumerConfiguration.h
1 
19 #ifndef PULSAR_CONSUMERCONFIGURATION_H_
20 #define PULSAR_CONSUMERCONFIGURATION_H_
21 
22 #include <boost/function.hpp>
23 #include <boost/shared_ptr.hpp>
24 #include <pulsar/Result.h>
25 #include <pulsar/ConsumerType.h>
26 #include <pulsar/Message.h>
27 
28 #pragma GCC visibility push(default)
29 namespace pulsar {
30 
31 class Consumer;
32 class PulsarWrapper;
33 
35 typedef boost::function<void(Result result)> ResultCallback;
36 
38 typedef boost::function<void(Consumer consumer, const Message& msg)> MessageListener;
39 
40 class ConsumerConfigurationImpl;
41 
46  public:
51 
65  ConsumerType getConsumerType() const;
66 
72  ConsumerConfiguration& setMessageListener(MessageListener messageListener);
73  MessageListener getMessageListener() const;
74  bool hasMessageListener() const;
75 
94  void setReceiverQueueSize(int size);
95  int getReceiverQueueSize() const;
96 
97  void setConsumerName(const std::string&);
98  const std::string& getConsumerName() const;
99 
107  void setUnAckedMessagesTimeoutMs(const uint64_t milliSeconds);
108 
112  long getUnAckedMessagesTimeoutMs() const;
113 
118  void setBrokerConsumerStatsCacheTimeInMs(const long cacheTimeInMs);
119 
124  friend class PulsarWrapper;
125 
126  private:
127  boost::shared_ptr<ConsumerConfigurationImpl> impl_;
128 };
129 
130 }
131 #pragma GCC visibility pop
132 #endif /* PULSAR_CONSUMERCONFIGURATION_H_ */
133 
ConsumerType
Definition: ConsumerType.h:24
boost::function< void(Result result)> ResultCallback
Callback definition for non-data operation.
Definition: ConsumerConfiguration.h:32
void setUnAckedMessagesTimeoutMs(const uint64_t milliSeconds)
Definition: Authentication.h:31
Definition: ConsumerConfiguration.h:45
ConsumerConfiguration & setConsumerType(ConsumerType consumerType)
void setBrokerConsumerStatsCacheTimeInMs(const long cacheTimeInMs)
long getBrokerConsumerStatsCacheTimeInMs() const
long getUnAckedMessagesTimeoutMs() const
boost::function< void(Consumer consumer, const Message &msg)> MessageListener
Callback definition for MessageListener.
Definition: ConsumerConfiguration.h:38
void setReceiverQueueSize(int size)
ConsumerConfiguration & setMessageListener(MessageListener messageListener)