OmniEvents::ProxyPullSupplierManager Class Reference
#include <ProxyPullSupplier.h>
Public Member Functions | |
| PortableServer::Servant | incarnate (const PortableServer::ObjectId &oid, PortableServer::POA_ptr poa) |
| ProxyPullSupplierManager (const EventChannel_i &channel, PortableServer::POA_ptr parentPoa, EventQueue &q) | |
| ~ProxyPullSupplierManager () | |
| OMNIEVENTS__DEBUG_REF_COUNTS__DECL CosEventChannelAdmin::ProxyPullSupplier_ptr | createObject () |
| void | disconnect () |
| Send disconnect_pull_consumer() to all connected PullConsumers. | |
Private Attributes | |
| const EventChannel_i & | _channel |
| EventQueue & | _queue |
| Reference to queue shared with ProxyPushSuppliers. | |
| int | _maxNumProxies |
| Upper limit on number of proxies. | |
Detailed Description
Definition at line 50 of file ProxyPullSupplier.h.
Constructor & Destructor Documentation
| OmniEvents::ProxyPullSupplierManager::ProxyPullSupplierManager | ( | const EventChannel_i & | channel, | |
| PortableServer::POA_ptr | parentPoa, | |||
| EventQueue & | q | |||
| ) |
Definition at line 62 of file ProxyPullSupplier.cc.
References OmniEvents::ProxyManager::activate().
| OmniEvents::ProxyPullSupplierManager::~ProxyPullSupplierManager | ( | ) |
Definition at line 74 of file ProxyPullSupplier.cc.
References DB.
Member Function Documentation
| CosEventChannelAdmin::ProxyPullSupplier_ptr OmniEvents::ProxyPullSupplierManager::createObject | ( | ) |
Definition at line 82 of file ProxyPullSupplier.cc.
Referenced by OmniEvents::ConsumerAdmin_i::obtain_pull_supplier().
| void OmniEvents::ProxyPullSupplierManager::disconnect | ( | ) |
Send disconnect_pull_consumer() to all connected PullConsumers.
Definition at line 90 of file ProxyPullSupplier.cc.
References OmniEvents::ProxyManager::_servants, and OmniEvents::ProxyPullSupplier_i::disconnect_pull_supplier().
Referenced by OmniEvents::ConsumerAdmin_i::disconnect().
| PortableServer::Servant OmniEvents::ProxyPullSupplierManager::incarnate | ( | const PortableServer::ObjectId & | oid, | |
| PortableServer::POA_ptr | poa | |||
| ) |
Definition at line 37 of file ProxyPullSupplier.cc.
References _channel, OmniEvents::ProxyManager::_managedPoa, _queue, OmniEvents::ProxyManager::_servants, DB, OmniEvents::ProxyPullSupplier_i::disconnect_pull_supplier(), OmniEvents::EventChannel_i::maxNumProxies(), and OmniEvents::ProxyPullSupplier_i::timestamp().
Member Data Documentation
const EventChannel_i& OmniEvents::ProxyPullSupplierManager::_channel [private] |
Definition at line 73 of file ProxyPullSupplier.h.
Referenced by incarnate().
int OmniEvents::ProxyPullSupplierManager::_maxNumProxies [private] |
Upper limit on number of proxies.
Definition at line 75 of file ProxyPullSupplier.h.
Reference to queue shared with ProxyPushSuppliers.
Definition at line 74 of file ProxyPullSupplier.h.
Referenced by incarnate().
The documentation for this class was generated from the following files:
