#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] |