ewmscp  ..
messageQueue.h
Go to the documentation of this file.
1 #ifndef __messageQueue_h__
2 #define __messageQueue_h__
3 #include <chrono>
4 #include <string>
5 
6 
7 namespace messageQueue {
8  class queue {
9  std::string name;
10  public:
11  queue(const std::string& aName): name(aName) {};
12  virtual ~queue() = default;
13  virtual void send(const std::string& aMessage,
14  const std::string& aTopic = "") = 0;
15  virtual std::string receive(std::chrono::system_clock::duration timeout) = 0;
16  virtual bool isSenderConfigured() const = 0;
17  virtual bool isReceiverConfigured() const = 0;
18  };
19 
20 
21 
22 } // end namespace messageQueue
23 
24 
25 
26 #endif
messageQueue::queue::queue
queue(const std::string &aName)
Definition: messageQueue.h:11
messageQueue::queue::~queue
virtual ~queue()=default
messageQueue::queue::name
std::string name
Definition: messageQueue.h:9
messageQueue::queue::send
virtual void send(const std::string &aMessage, const std::string &aTopic="")=0
messageQueue::queue::receive
virtual std::string receive(std::chrono::system_clock::duration timeout)=0
messageQueue::queue::isSenderConfigured
virtual bool isSenderConfigured() const =0
messageQueue::queue
Definition: messageQueue.h:8
messageQueue::queue::isReceiverConfigured
virtual bool isReceiverConfigured() const =0
messageQueue
Definition: kafkaQueue.cpp:5