24 #include "MessageType.h"
29 typedef std::shared_ptr<uniset::VoidMessage> VoidMessagePtr;
49 void push(
const VoidMessagePtr& msg );
54 VoidMessagePtr
top() noexcept;
62 void setMaxSizeOfMessageQueue(
size_t s ) noexcept;
63 size_t getMaxSizeOfMessageQueue()
const noexcept;
78 return stMaxQueueMessages;
84 return stCountOfLostMessages;
92 typedef std::deque<VoidMessagePtr> MQueue;
100 size_t SizeOfMessageQueue = { 2000 };
103 size_t stMaxQueueMessages = { 0 };
104 size_t stCountOfLostMessages = { 0 };
Definition: CallbackTimer.h:29
LostStrategy
Definition: MQMutex.h:66
void push(const VoidMessagePtr &msg)
Definition: MQMutex.cc:30
VoidMessagePtr top() noexcept
Definition: MQMutex.cc:58
size_t getMaxQueueMessages() const noexcept
Definition: MQMutex.h:76
size_t getCountOfLostMessages() const noexcept
Definition: MQMutex.h:82