Consumer.h

 
#ifndef CONSUMER_HPP_
#define CONSUMER_HPP_
 
#include <iostream>
#include <pulsar/BrokerConsumerStats.h>
#include <pulsar/ConsumerConfiguration.h>
#pragma GCC visibility push(default)
 
namespace pulsar {
class PulsarWrapper;
class ConsumerImplBase;
class PulsarFriend;
typedef std::shared_ptr<ConsumerImplBase> ConsumerImplBasePtr;
class Consumer {
   public:
    Consumer();
 
    const std::string& getTopic() const;
 
    const std::string& getSubscriptionName() const;
 
    Result unsubscribe();
 
    void unsubscribeAsync(ResultCallback callback);
 
    Result receive(Message& msg);
 
    Result receive(Message& msg, int timeoutMs);
 
    void receiveAsync(ReceiveCallback callback);
 
    Result acknowledge(const Message& message);
    Result acknowledge(const MessageId& messageId);
 
    void acknowledgeAsync(const Message& message, ResultCallback callback);
    void acknowledgeAsync(const MessageId& messageID, ResultCallback callback);
 
    Result acknowledgeCumulative(const Message& message);
    Result acknowledgeCumulative(const MessageId& messageId);
 
    void acknowledgeCumulativeAsync(const Message& message, ResultCallback callback);
    void acknowledgeCumulativeAsync(const MessageId& messageId, ResultCallback callback);
 
    Result close();
 
    void closeAsync(ResultCallback callback);
 
    /*
     * Pause receiving messages via the messageListener, till resumeMessageListener() is called.
     */
    Result pauseMessageListener();
 
    /*
     * Resume receiving the messages via the messageListener.
     * Asynchronously receive all the messages enqueued from time pauseMessageListener() was called.
     */
    Result resumeMessageListener();
 
    void redeliverUnacknowledgedMessages();
 
    Result getBrokerConsumerStats(BrokerConsumerStats& brokerConsumerStats);
 
    void getBrokerConsumerStatsAsync(BrokerConsumerStatsCallback callback);
 
    Result seek(const MessageId& msgId);
 
    virtual void seekAsync(const MessageId& msgId, ResultCallback callback);
 
   private:
    ConsumerImplBasePtr impl_;
    explicit Consumer(ConsumerImplBasePtr);
 
    friend class PulsarFriend;
    friend class PulsarWrapper;
    friend class PartitionedConsumerImpl;
    friend class MultiTopicsConsumerImpl;
    friend class ConsumerImpl;
    friend class ClientImpl;
    friend class ConsumerTest;
};
}  // namespace pulsar
 
#pragma GCC visibility pop
 
#endif /* CONSUMER_HPP_ */