#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. | |
Private Attributes | |
const EventChannel_i & | _channel |
EventQueue | _queue |
ProxyPushSupplierManager * | _pushSupplier |
ProxyPullSupplierManager * | _pullSupplier |
Definition at line 54 of file ConsumerAdmin.h.
OmniEvents::ConsumerAdmin_i::ConsumerAdmin_i | ( | const EventChannel_i & | channel, | |
PortableServer::POA_ptr | poa | |||
) |
Definition at line 50 of file ConsumerAdmin.cc.
OmniEvents::ConsumerAdmin_i::~ConsumerAdmin_i | ( | ) | [virtual] |
Definition at line 76 of file ConsumerAdmin.cc.
void OmniEvents::ConsumerAdmin_i::disconnect | ( | ) |
Send disconnect_XXX_consumer() to all connected consumers.
Definition at line 114 of file ConsumerAdmin.cc.
CosEventChannelAdmin::ProxyPullSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_pull_supplier | ( | ) |
Definition at line 42 of file ConsumerAdmin.cc.
CosEventChannelAdmin::ProxyPushSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_push_supplier | ( | ) |
Definition at line 33 of file ConsumerAdmin.cc.
References OmniEvents::Servant::_poa, _pushSupplier, _queue, and OmniEvents::ProxyPushSupplierManager::createObject().
void OmniEvents::ConsumerAdmin_i::output | ( | ostream & | os | ) |
Save this object's state to a stream.
Definition at line 143 of file ConsumerAdmin.cc.
void OmniEvents::ConsumerAdmin_i::reincarnate | ( | const PersistNode & | node | ) |
Populate this servant from log information.
Definition at line 123 of file ConsumerAdmin.cc.
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 102 of file ConsumerAdmin.cc.
void OmniEvents::ConsumerAdmin_i::send | ( | CORBA::Any * | event | ) |
Queues a single event for sending to consumers.
Takes ownership of the event.
Definition at line 95 of file ConsumerAdmin.cc.
const EventChannel_i& OmniEvents::ConsumerAdmin_i::_channel [private] |
Definition at line 88 of file ConsumerAdmin.h.
Definition at line 91 of file ConsumerAdmin.h.
Definition at line 90 of file ConsumerAdmin.h.
Referenced by obtain_push_supplier().
Definition at line 89 of file ConsumerAdmin.h.
Referenced by obtain_push_supplier().