#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. More... | |
 Public Member Functions inherited from OmniEvents::ProxyManager | |
| void | etherealize (const PortableServer::ObjectId &oid, PortableServer::POA_ptr adapter, PortableServer::Servant serv, CORBA::Boolean cleanup_in_progress, CORBA::Boolean remaining_activations) |
| Implements etherealize() method from ServantActivator interface. More... | |
| void | reincarnate (const PersistNode &node) |
| Re-create servants from information saved in the log file. More... | |
| void | output (ostream &os) |
| Save this object's state to a stream. More... | |
| Public Member Functions inherited from OmniEvents::Servant | |
| virtual PortableServer::POA_ptr | _default_POA () |
| virtual | ~Servant () |
Private Attributes | |
| const EventChannel_i & | _channel |
| EventQueue & | _queue |
| Reference to queue shared with ProxyPushSuppliers. More... | |
| int | _maxNumProxies |
| Upper limit on number of proxies. More... | |
Additional Inherited Members | |
| Protected Member Functions inherited from OmniEvents::ProxyManager | |
| ProxyManager (PortableServer::POA_ptr poa) | |
| virtual | ~ProxyManager () |
| void | activate (const char *name) |
| Creates the Proxy-type's POA, and registers this object as its ServantManager. More... | |
| Protected Member Functions inherited from OmniEvents::Servant | |
| Servant (PortableServer::POA_ptr poa) | |
| void | activateObjectWithId (const char *oidStr) |
| Calls activate_object_with_id() to activate this servant in its POA. More... | |
| void | deactivateObject () |
| Calls deactivate_object() to deactivate this servant in its POA. More... | |
| Protected Attributes inherited from OmniEvents::ProxyManager | |
| set< Proxy * > | _servants |
| The set of all active Proxies in this object's _managedPoa. More... | |
| PortableServer::POA_var | _managedPoa |
| The POA owned & managed by this object. More... | |
| Protected Attributes inherited from OmniEvents::Servant | |
| PortableServer::POA_var | _poa |
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
|
private |
Definition at line 73 of file ProxyPullSupplier.h.
Referenced by incarnate().
|
private |
Upper limit on number of proxies.
Definition at line 75 of file ProxyPullSupplier.h.
|
private |
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:
