24 #include "MessageType.h" 26 typedef std::shared_ptr<uniset::VoidMessage> VoidMessagePtr;
68 bool push(
const VoidMessagePtr& msg ) noexcept;
73 VoidMessagePtr
top() noexcept;
75 size_t size()
const noexcept;
76 bool empty()
const noexcept;
81 void setMaxSizeOfMessageQueue(
size_t s );
82 size_t getMaxSizeOfMessageQueue()
const noexcept;
97 return stMaxQueueMessages;
103 return stCountOfLostMessages;
109 void mqFill(
const VoidMessagePtr& v );
113 void set_wpos(
unsigned long pos ) noexcept;
114 void set_rpos(
unsigned long pos ) noexcept;
118 typedef std::vector<VoidMessagePtr> MQueue;
121 std::atomic_ulong wpos = { 0 };
122 std::atomic_ulong rpos = { 0 };
123 std::atomic_ulong qpos = { 0 };
128 size_t SizeOfMessageQueue = { 2000 };
131 size_t stMaxQueueMessages = { 0 };
132 size_t stCountOfLostMessages = { 0 };
size_t getCountOfLostMessages() const noexcept
Definition: MQAtomic.h:101
Definition: CommonEventLoop.h:14
Definition: MQAtomic.h:62
LostStrategy
Definition: MQAtomic.h:85
size_t getMaxQueueMessages() const noexcept
Definition: MQAtomic.h:95
bool push(const VoidMessagePtr &msg) noexcept
Definition: MQAtomic.cc:31
VoidMessagePtr top() noexcept
Definition: MQAtomic.cc:75