OmniEvents
|
#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. |
Definition at line 50 of file ProxyPullSupplier.h.
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.
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().
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().