#include <ConsumerAdmin.h>
Public Member Functions | |
| CosEventChannelAdmin::ProxyPushSupplier_ptr | obtain_push_supplier () |
| CosEventChannelAdmin::ProxyPullSupplier_ptr | obtain_pull_supplier () |
| ConsumerAdmin_i (const EventChannel_i &channel, PortableServer::POA_ptr poa) | |
| virtual | ~ConsumerAdmin_i () |
| OMNIEVENTS__DEBUG_REF_COUNTS__DECL void | send (CORBA::Any *event) |
| Queues a single event for sending to consumers. More... | |
| void | send (list< CORBA::Any * > &events) |
| Queues up events for sending to consumers. More... | |
| void | disconnect () |
| Send disconnect_XXX_consumer() to all connected consumers. More... | |
| void | reincarnate (const PersistNode &node) |
| Populate this servant from log information. 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 |
| ProxyPushSupplierManager * | _pushSupplier |
| ProxyPullSupplierManager * | _pullSupplier |
Additional Inherited Members | |
| 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::Servant | |
| PortableServer::POA_var | _poa |
Detailed Description
Definition at line 54 of file ConsumerAdmin.h.
Constructor & Destructor Documentation
◆ ConsumerAdmin_i()
| OmniEvents::ConsumerAdmin_i::ConsumerAdmin_i | ( | const EventChannel_i & | channel, |
| PortableServer::POA_ptr | poa | ||
| ) |
Definition at line 54 of file ConsumerAdmin.cc.
References _channel, _queue, OmniEvents::Servant::activateObjectWithId(), OmniEvents::PersistNode::attrLong(), OmniEvents::PersistNode::attrString(), OmniEvents::PersistNode::hasAttr(), OmniEvents::EventChannel_i::properties(), and OmniEvents::EventQueue::setFilter().
◆ ~ConsumerAdmin_i()
|
virtual |
Definition at line 80 of file ConsumerAdmin.cc.
References _pullSupplier, _pushSupplier, OmniEvents::ProxyPushSupplierManager::_remove_ref(), and DB.
Member Function Documentation
◆ disconnect()
| void OmniEvents::ConsumerAdmin_i::disconnect | ( | ) |
Send disconnect_XXX_consumer() to all connected consumers.
Definition at line 118 of file ConsumerAdmin.cc.
References _pullSupplier, _pushSupplier, OmniEvents::ProxyPullSupplierManager::disconnect(), and OmniEvents::ProxyPushSupplierManager::disconnect().
Referenced by OmniEvents::EventChannel_i::destroy().
◆ obtain_pull_supplier()
| CosEventChannelAdmin::ProxyPullSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_pull_supplier | ( | ) |
Definition at line 46 of file ConsumerAdmin.cc.
References _channel, OmniEvents::Servant::_poa, _pullSupplier, _queue, and OmniEvents::ProxyPullSupplierManager::createObject().
◆ obtain_push_supplier()
| CosEventChannelAdmin::ProxyPushSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_push_supplier | ( | ) |
Definition at line 37 of file ConsumerAdmin.cc.
References OmniEvents::Servant::_poa, _pushSupplier, _queue, and OmniEvents::ProxyPushSupplierManager::createObject().
◆ output()
| void OmniEvents::ConsumerAdmin_i::output | ( | ostream & | os | ) |
Save this object's state to a stream.
Definition at line 147 of file ConsumerAdmin.cc.
References OmniEvents::ProxyPushSupplierManager::_lock, _pullSupplier, _pushSupplier, and OmniEvents::ProxyManager::output().
Referenced by OmniEvents::EventChannel_i::output().
◆ reincarnate()
| void OmniEvents::ConsumerAdmin_i::reincarnate | ( | const PersistNode & | node | ) |
Populate this servant from log information.
Definition at line 127 of file ConsumerAdmin.cc.
References _channel, OmniEvents::PersistNode::_child, OmniEvents::Servant::_poa, _pullSupplier, _pushSupplier, _queue, OmniEvents::PersistNode::child(), and OmniEvents::ProxyManager::reincarnate().
Referenced by OmniEvents::EventChannel_i::activate().
◆ send() [1/2]
| void OmniEvents::ConsumerAdmin_i::send | ( | CORBA::Any * | event | ) |
Queues a single event for sending to consumers.
Takes ownership of the event.
Definition at line 99 of file ConsumerAdmin.cc.
Referenced by OmniEvents::EventChannel_i::mainLoop(), and OmniEvents::ProxyPushConsumer_i::push().
◆ send() [2/2]
| void OmniEvents::ConsumerAdmin_i::send | ( | list< CORBA::Any * > & | events | ) |
Queues up events for sending to consumers.
Takes ownership of the events. On exit, the 'events' parameter is empty.
Definition at line 106 of file ConsumerAdmin.cc.
References _pushSupplier, _queue, and OmniEvents::EventQueue::append().
Member Data Documentation
◆ _channel
|
private |
Definition at line 88 of file ConsumerAdmin.h.
Referenced by ConsumerAdmin_i(), obtain_pull_supplier(), and reincarnate().
◆ _pullSupplier
|
private |
Definition at line 91 of file ConsumerAdmin.h.
Referenced by disconnect(), obtain_pull_supplier(), output(), reincarnate(), and ~ConsumerAdmin_i().
◆ _pushSupplier
|
private |
Definition at line 90 of file ConsumerAdmin.h.
Referenced by disconnect(), obtain_push_supplier(), output(), reincarnate(), send(), and ~ConsumerAdmin_i().
◆ _queue
|
private |
Definition at line 89 of file ConsumerAdmin.h.
Referenced by ConsumerAdmin_i(), obtain_pull_supplier(), obtain_push_supplier(), reincarnate(), and send().
The documentation for this class was generated from the following files:
