#include <messageserver.h>

Public Member Functions | |
| MessageServer (const char *id) | |
| virtual | ~MessageServer () |
| bool | Run () |
| void | Stop () |
| void | SendMessage (BaseMessage *message, Root *sender, Root *destination, double delay=0.0) |
| void | CancelMessage (BaseMessage *message) |
Static Private Member Functions | |
| static void | OnProcess (void *data) |
Private Attributes | |
| bool | running |
| List< BaseMessage > | queue |
| Queue of messages to deliver immediately. | |
| Ref< TimeServer > | time_server |
| Thread * | thread |
| Semaphore * | semaphore |
| MessageServer::MessageServer | ( | const char * | id | ) |
| MessageServer::~MessageServer | ( | ) | [virtual] |
| bool MessageServer::Run | ( | ) |
| void MessageServer::Stop | ( | ) |
| void MessageServer::SendMessage | ( | BaseMessage * | message, | |
| Root * | sender, | |||
| Root * | destination, | |||
| double | delay = 0.0 | |||
| ) |
| void MessageServer::CancelMessage | ( | BaseMessage * | message | ) |
| void MessageServer::OnProcess | ( | void * | data | ) | [static, private] |
bool MessageServer::running [private] |
List<BaseMessage> MessageServer::queue [private] |
Queue of messages to deliver immediately.
Ref<TimeServer> MessageServer::time_server [private] |
Thread* MessageServer::thread [private] |
Semaphore* MessageServer::semaphore [private] |
1.5.3