OmniEvents
|
#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. | |
void | send (list< CORBA::Any * > &events) |
Queues up events for sending to consumers. | |
void | disconnect () |
Send disconnect_XXX_consumer() to all connected consumers. | |
void | reincarnate (const PersistNode &node) |
Populate this servant from log information. | |
void | output (ostream &os) |
Save this object's state to a stream. | |
![]() | |
virtual PortableServer::POA_ptr | _default_POA () |
virtual | ~Servant () |
Private Attributes | |
const EventChannel_i & | _channel |
EventQueue | _queue |
ProxyPushSupplierManager * | _pushSupplier |
ProxyPullSupplierManager * | _pullSupplier |
Additional Inherited Members | |
![]() | |
Servant (PortableServer::POA_ptr poa) | |
void | activateObjectWithId (const char *oidStr) |
Calls activate_object_with_id() to activate this servant in its POA. | |
void | deactivateObject () |
Calls deactivate_object() to deactivate this servant in its POA. | |
![]() | |
PortableServer::POA_var | _poa |
Definition at line 54 of file ConsumerAdmin.h.
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().
|
virtual |
Definition at line 80 of file ConsumerAdmin.cc.
References _pullSupplier, _pushSupplier, OmniEvents::ProxyPushSupplierManager::_remove_ref(), and DB.
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().
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().
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().
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().
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().
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().
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().
|
private |
Definition at line 88 of file ConsumerAdmin.h.
Referenced by ConsumerAdmin_i(), obtain_pull_supplier(), and reincarnate().
|
private |
Definition at line 91 of file ConsumerAdmin.h.
Referenced by disconnect(), obtain_pull_supplier(), output(), reincarnate(), and ~ConsumerAdmin_i().
|
private |
Definition at line 90 of file ConsumerAdmin.h.
Referenced by disconnect(), obtain_push_supplier(), output(), reincarnate(), send(), and ~ConsumerAdmin_i().
|
private |
Definition at line 89 of file ConsumerAdmin.h.
Referenced by ConsumerAdmin_i(), obtain_pull_supplier(), obtain_push_supplier(), reincarnate(), and send().