|
version 1.85, 2006/07/21 18:44:08
|
version 1.86, 2006/07/23 18:02:40
|
|
|
|
| else | else |
| { | { |
| asyncRequest = new AsyncLegacyOperationStart( | asyncRequest = new AsyncLegacyOperationStart( |
| get_next_xid(), |
|
| 0, | 0, |
| this->getQueueId(), | this->getQueueId(), |
| message, | message, |
|
|
|
| | |
| AsyncLegacyOperationResult * async_result = | AsyncLegacyOperationResult * async_result = |
| new AsyncLegacyOperationResult( | new AsyncLegacyOperationResult( |
| async->getRouting(), |
|
| op, | op, |
| response); | response); |
| | |
|
|
|
| PEGASUS_ASSERT(op); | PEGASUS_ASSERT(op); |
| PEGASUS_ASSERT(!response->_async); | PEGASUS_ASSERT(!response->_async); |
| response->_async = new AsyncLegacyOperationResult( | response->_async = new AsyncLegacyOperationResult( |
| requestAsync->getRouting(), op, response); |
op, response); |
| | |
| // set the destination | // set the destination |
| op->_op_dest = op->_callback_response_q; | op->_op_dest = op->_callback_response_q; |
|
|
|
| | |
| AsyncLegacyOperationStart * asyncRequest = | AsyncLegacyOperationStart * asyncRequest = |
| new AsyncLegacyOperationStart( | new AsyncLegacyOperationStart( |
| providerManagerService->get_next_xid(), |
|
| 0, | 0, |
| _indicationServiceQueueId, | _indicationServiceQueueId, |
| request, | request, |
|
|
|
| request->queueIds = QueueIdStack | request->queueIds = QueueIdStack |
| (_indicationServiceQueueId, providerManagerService->getQueueId ()); | (_indicationServiceQueueId, providerManagerService->getQueueId ()); |
| | |
| AsyncLegacyOperationStart * asyncRequest = new AsyncLegacyOperationStart |
AsyncLegacyOperationStart * asyncRequest = new AsyncLegacyOperationStart( |
| (providerManagerService->get_next_xid (), |
|
| 0, | 0, |
| _indicationServiceQueueId, | _indicationServiceQueueId, |
| request, | request, |
Return to
ProviderManagerService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Attic