22 #include <boost/date_time/posix_time/ptime.hpp> 24 #include <pulsar/BrokerConsumerStats.h> 25 #include <pulsar/ConsumerConfiguration.h> 26 #pragma GCC visibility push(default) 31 class ConsumerImplBase;
168 Result pauseMessageListener();
174 Result resumeMessageListener();
207 typedef boost::shared_ptr<ConsumerImplBase> ConsumerImplBasePtr;
208 ConsumerImplBasePtr impl_;
209 explicit Consumer(ConsumerImplBasePtr);
211 friend class PulsarFriend;
212 friend class PulsarWrapper;
213 friend class PartitionedConsumerImpl;
214 friend class ConsumerImpl;
215 friend class ClientImpl;
216 friend class ConsumerTest;
221 #pragma GCC visibility pop Result acknowledgeCumulative(const Message &message)
boost::function< void(Result result)> ResultCallback
Callback definition for non-data operation.
Definition: ConsumerConfiguration.h:32
Definition: Authentication.h:31
void acknowledgeAsync(const Message &message, ResultCallback callback)
void unsubscribeAsync(ResultCallback callback)
const std::string & getSubscriptionName() const
void acknowledgeCumulativeAsync(const Message &message, ResultCallback callback)
Definition: Consumer.h:36
Result getBrokerConsumerStats(BrokerConsumerStats &brokerConsumerStats)
Result
Definition: Result.h:31
void redeliverUnacknowledgedMessages()
Result acknowledge(const Message &message)
const std::string & getTopic() const
Result receive(Message &msg)
Definition: MessageId.h:33
void getBrokerConsumerStatsAsync(BrokerConsumerStatsCallback callback)
Definition: BrokerConsumerStats.h:35