ewmscp
..
src
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
Generated by
1.8.17