|
version 1.21, 2002/03/11 14:58:54
|
version 1.23, 2002/04/12 00:58:21
|
|
|
|
| | |
| typedef MessageQueue Base; | typedef MessageQueue Base; |
| | |
| MessageQueueService(const char *name, Uint32 queueID, |
MessageQueueService(const char *name, |
| |
Uint32 queueID = MessageQueue::getNextQueueId(), |
| Uint32 capabilities = 0, | Uint32 capabilities = 0, |
| Uint32 mask = message_mask::type_cimom | | Uint32 mask = message_mask::type_cimom | |
| message_mask::type_service | | message_mask::type_service | |
|
|
|
| virtual void handleEnqueue(void) = 0; | virtual void handleEnqueue(void) = 0; |
| virtual void handleEnqueue(Message *) = 0; | virtual void handleEnqueue(Message *) = 0; |
| Boolean _enqueueResponse(Message *, Message *); | Boolean _enqueueResponse(Message *, Message *); |
| virtual void _handle_incoming_operation(AsyncOpNode *operation, Thread *thread, MessageQueue *queue); |
// virtual void _handle_incoming_operation(AsyncOpNode *operation, Thread *thread, MessageQueue *queue); |
| |
virtual void _handle_incoming_operation(AsyncOpNode *); |
| |
|
| virtual void _handle_async_request(AsyncRequest *req); | virtual void _handle_async_request(AsyncRequest *req); |
| virtual void _handle_async_callback(AsyncOpNode *operation); | virtual void _handle_async_callback(AsyncOpNode *operation); |
| virtual void _make_response(Message *req, Uint32 code); | virtual void _make_response(Message *req, Uint32 code); |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common