version 1.13, 2002/02/06 15:15:35
|
version 1.14, 2002/02/07 00:28:48
|
|
|
| |
#include "MessageQueueService.h" | #include "MessageQueueService.h" |
| |
PEGASUS_USING_STD; |
|
|
|
PEGASUS_NAMESPACE_BEGIN | PEGASUS_NAMESPACE_BEGIN |
| |
MessageQueueService::MessageQueueService(const char *name, | MessageQueueService::MessageQueueService(const char *name, |
|
|
else if (type == async_messages::CIMSERVICE_STOP) | else if (type == async_messages::CIMSERVICE_STOP) |
handle_CimServiceStop(static_cast<CimServiceStop *>(req)); | handle_CimServiceStop(static_cast<CimServiceStop *>(req)); |
else if (type == async_messages::CIMSERVICE_PAUSE) | else if (type == async_messages::CIMSERVICE_PAUSE) |
{ |
|
handle_CimServicePause(static_cast<CimServicePause *>(req)); | handle_CimServicePause(static_cast<CimServicePause *>(req)); |
} |
|
|
|
else if (type == async_messages::CIMSERVICE_RESUME) | else if (type == async_messages::CIMSERVICE_RESUME) |
handle_CimServiceResume(static_cast<CimServiceResume *>(req)); | handle_CimServiceResume(static_cast<CimServiceResume *>(req)); |
else if ( type == async_messages::ASYNC_OP_START) | else if ( type == async_messages::ASYNC_OP_START) |
|
|
| |
void MessageQueueService::handle_AsyncOperationResult(AsyncOperationResult *req) | void MessageQueueService::handle_AsyncOperationResult(AsyncOperationResult *req) |
{ | { |
|
; |
|
} |
|
|
|
|
|
void MessageQueueService::handle_AsyncLegacyOperationStart(AsyncLegacyOperationStart *req) |
|
{ |
|
// remove the legacy message from the request and enqueue it to its destination |
|
Uint32 result = async_results::CIM_NAK; |
| |
|
Message *legacy = req->act; |
|
if ( legacy != 0 ) |
|
{ |
|
MessageQueue* queue = MessageQueue::lookup(req->legacy_destination); |
|
if( queue != 0 ) |
|
{ |
|
// Enqueue the response: |
|
queue->enqueue(legacy); |
|
result = async_results::OK; |
|
} |
|
} |
|
_make_response(req, result); |
|
} |
|
|
|
void MessageQueueService::handle_AsyncLegacyOperationResult(AsyncLegacyOperationResult *rep) |
|
{ |
|
; |
} | } |
| |
AsyncOpNode *MessageQueueService::get_op(void) | AsyncOpNode *MessageQueueService::get_op(void) |