version 1.39, 2012/02/20 07:00:55
|
version 1.40, 2013/11/20 11:34:12
|
|
|
const CIMPropertyList &propList); | const CIMPropertyList &propList); |
| |
/** | /** |
|
This method Cleanup all DestinationQueues |
|
Depending on flag _needDestinationQueueCleanup, this method is called |
|
either from IndicationHandlerService dtor or from _handleIndication |
|
*/ |
|
void _destinationQueuesCleanup(); |
|
|
|
/** |
Gets the Queue name from either subscriptionName or handlerName, | Gets the Queue name from either subscriptionName or handlerName, |
constructed as follows. | constructed as follows. |
namespace:ClassName.Name=\"HandlerName\". | namespace:ClassName.Name=\"HandlerName\". |
|
|
Thread _dispatcherThread; | Thread _dispatcherThread; |
AtomicInt _stopDispatcherThread; | AtomicInt _stopDispatcherThread; |
const Uint32 _maxDeliveryThreads; | const Uint32 _maxDeliveryThreads; |
|
Uint16 _maxDeliveryRetry; |
|
Boolean _needDestinationQueueCleanup; |
Semaphore _dispatcherWaitSemaphore; | Semaphore _dispatcherWaitSemaphore; |
static ThreadReturnType PEGASUS_THREAD_CDECL | static ThreadReturnType PEGASUS_THREAD_CDECL |
_dispatcherRoutine(void *param); | _dispatcherRoutine(void *param); |