| 239 | //----------------------------------------------------------------------------- |
| 240 | |
| 241 | bool dispatchMessage( const char* queue, const char* msg, const char* data) |
| 242 | { |
| 243 | AssertFatal( queue != NULL, "Dispatcher::dispatchMessage - Got a NULL queue name" ); |
| 244 | AssertFatal( msg != NULL, "Dispatcher::dispatchMessage - Got a NULL message" ); |
| 245 | |
| 246 | MutexHandle mh; |
| 247 | |
| 248 | if(! mh.lock(gDispatchData.mMutex, true)) |
| 249 | return true; |
| 250 | |
| 251 | MessageQueue *q = gDispatchData.mQueues.retreive(queue); |
| 252 | if(q == NULL) |
| 253 | { |
| 254 | Con::errorf("Dispatcher::dispatchMessage - Attempting to dispatch to unknown queue '%s'", queue); |
| 255 | return true; |
| 256 | } |
| 257 | |
| 258 | return q->dispatchMessage(msg, data); |
| 259 | } |
| 260 | |
| 261 | |
| 262 | bool dispatchMessageObject(const char *queue, Message *msg) |
no test coverage detected