#include <MessageQueueSystem.h>
◆ ~MessageQueueSystem()
virtual Demo::Mq::MessageQueueSystem::~MessageQueueSystem |
( |
| ) |
|
|
inlinevirtual |
◆ flushQueuedMessages()
void Demo::Mq::MessageQueueSystem::flushQueuedMessages |
( |
void |
| ) |
|
|
inline |
Sends all the messages queued via see queueSendMessage(); Must be called from the thread that owns 'this'.
◆ processIncomingMessage()
virtual void Demo::Mq::MessageQueueSystem::processIncomingMessage |
( |
Mq::MessageId |
messageId, |
|
|
const void * |
data |
|
) |
| |
|
protectedpure virtual |
◆ processIncomingMessages()
void Demo::Mq::MessageQueueSystem::processIncomingMessages |
( |
void |
| ) |
|
|
inlineprotected |
Processes all incoming messages received from other threads.
Should be called from the thread that owns 'this'
◆ queueSendMessage()
Queues message 'msg' to be sent to a destination MessageQueueSystem.
This function must be called from the thread that owns 'this' The 'dstSystem' may live in any other thread.
- Parameters
-
dstSystem | The MessageQueueSystem we want to send a message to. |
msg | The message itself. Structure must be POD. |
◆ receiveMessageImmediately()
template<typename T >
void Demo::Mq::MessageQueueSystem::receiveMessageImmediately |
( |
Mq::MessageId |
messageId, |
|
|
const T & |
msg |
|
) |
| |
|
inline |
Sends a message to 'this' base system immediately.
Use it only for time critical messages or if the sender thread doesn't own its own MessageQueueSystem class. Abusing this function can degrade performance as it would perform frequent locking. See queueSendMessage
The documentation for this class was generated from the following files: