19 #ifndef PULSAR_CONSUMERCONFIGURATION_H_ 20 #define PULSAR_CONSUMERCONFIGURATION_H_ 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> 28 #pragma GCC visibility push(default) 38 typedef boost::function<void(Consumer consumer, const Message& msg)>
MessageListener;
40 class ConsumerConfigurationImpl;
73 MessageListener getMessageListener()
const;
74 bool hasMessageListener()
const;
95 int getReceiverQueueSize()
const;
97 void setConsumerName(
const std::string&);
98 const std::string& getConsumerName()
const;
124 friend class PulsarWrapper;
127 boost::shared_ptr<ConsumerConfigurationImpl> impl_;
131 #pragma GCC visibility pop 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)