|
version 1.143, 2008/09/16 18:37:03
|
version 1.144, 2008/09/17 05:57:05
|
|
|
|
| { | { |
| } | } |
| | |
| |
|
| 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) |
|
| { |
|
| if (queue->isAsync() == true) |
|
| { |
|
| (static_cast<MessageQueueService *>(queue))->handleEnqueue( |
|
| legacy); |
|
| } |
|
| else |
|
| { |
|
| // Enqueue the response: |
|
| queue->enqueue(req->get_action()); |
|
| } |
|
| |
|
| result = async_results::OK; |
|
| } |
|
| } |
|
| _make_response(req, result); |
|
| } |
|
| |
|
| void MessageQueueService::handle_AsyncLegacyOperationResult( |
|
| AsyncLegacyOperationResult* rep) |
|
| { |
|
| } |
|
| |
|
| AsyncOpNode* MessageQueueService::get_op() | AsyncOpNode* MessageQueueService::get_op() |
| { | { |
| AsyncOpNode* op = new AsyncOpNode(); | AsyncOpNode* op = new AsyncOpNode(); |
|
|
|
| AsyncLegacyOperationStart *wrapper = new AsyncLegacyOperationStart( | AsyncLegacyOperationStart *wrapper = new AsyncLegacyOperationStart( |
| op, | op, |
| destination, | destination, |
| msg, |
msg); |
| destination); |
|
| } | } |
| else | else |
| { | { |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common