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. | |
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 58 of file ConsumerAdmin.cc.
OmniEvents::ConsumerAdmin_i::~ConsumerAdmin_i | ( | ) | [virtual] |
Definition at line 84 of file ConsumerAdmin.cc.
void OmniEvents::ConsumerAdmin_i::disconnect | ( | ) |
Send disconnect_XXX_consumer() to all connected consumers.
Definition at line 122 of file ConsumerAdmin.cc.
CosEventChannelAdmin::ProxyPullSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_pull_supplier | ( | ) |
Definition at line 50 of file ConsumerAdmin.cc.
build buildd omnievents src ConsumerAdmin cc build buildd omnievents src ConsumerAdmin cc build buildd omnievents src ConsumerAdmin cc build buildd omnievents src ConsumerAdmin cc CosEventChannelAdmin::ProxyPushSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_push_supplier | ( | ) |
Definition at line 41 of file ConsumerAdmin.cc.
void OmniEvents::ConsumerAdmin_i::output | ( | ostream & | os | ) |
Save this object's state to a stream.
Definition at line 151 of file ConsumerAdmin.cc.
void OmniEvents::ConsumerAdmin_i::reincarnate | ( | const PersistNode & | node | ) |
Populate this servant from log information.
Definition at line 131 of file ConsumerAdmin.cc.
References OmniEvents::Servant::_poa, _pushSupplier, _queue, 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 103 of file ConsumerAdmin.cc.
Referenced by OmniEvents::ProxyPushConsumer_i::push().
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 110 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 reincarnate().
Definition at line 89 of file ConsumerAdmin.h.
Referenced by reincarnate().