kafkaQueue.h

Go to the documentation of this file.

#ifndef __kafkaQueue_h__
#define __kafkaQueue_h__
 
#include "messageQueue.h"
#include <Options.h>
#include <memory>
namespace RdKafka { // for forward decls;
    class Topic;
    class Producer;
    class Consumer;
    class Conf;
}
namespace messageQueue {
    class kafka: public queue {
      private:
        std::map<std::string, std::unique_ptr<RdKafka::Topic>> topics;
        RdKafka::Producer* producer;
        RdKafka::Consumer* consumer;
        RdKafka::Conf *tconf;
        options::single<std::string> topicName;
        options::map<std::string> producerCfgStrings;
        options::map<std::string> topicCfgStrings;
      public:
        kafka(const std::string& aName);
        void init(bool isConsumer = false);
        ~kafka() override;
        void send(const std::string& aMessage,
                  const std::string& aTopic = "") override;
        std::string receive(std::chrono::system_clock::duration timeout) override;
        bool isSenderConfigured() const override;
        bool isReceiverConfigured() const override;
    };
} // end namespace messageQueue
#endif