OmniEvents::ConsumerAdmin_i Class Reference

#include <ConsumerAdmin.h>

Inheritance diagram for OmniEvents::ConsumerAdmin_i:

[legend]Collaboration diagram for OmniEvents::ConsumerAdmin_i:

[legend]List of all members.

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

---

Detailed Description

Definition at line 54 of file ConsumerAdmin.h.

---

Constructor & Destructor Documentation

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().

OmniEvents::ConsumerAdmin_i::~ConsumerAdmin_i (   )  [virtual]

Definition at line 80 of file ConsumerAdmin.cc. References _pullSupplier, _pushSupplier, OmniEvents::ProxyPushSupplierManager::_remove_ref(), and DB.

---

Member Function Documentation

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().

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().

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 (  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().

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().

---

Member Data Documentation

const EventChannel_i& OmniEvents::ConsumerAdmin_i::_channel [private]

Definition at line 88 of file ConsumerAdmin.h. Referenced by ConsumerAdmin_i(), obtain_pull_supplier(), and reincarnate().

ProxyPullSupplierManager* OmniEvents::ConsumerAdmin_i::_pullSupplier [private]

Definition at line 91 of file ConsumerAdmin.h. Referenced by disconnect(), obtain_pull_supplier(), output(), reincarnate(), and ~ConsumerAdmin_i().

ProxyPushSupplierManager* OmniEvents::ConsumerAdmin_i::_pushSupplier [private]

Definition at line 90 of file ConsumerAdmin.h. Referenced by disconnect(), obtain_push_supplier(), output(), reincarnate(), send(), and ~ConsumerAdmin_i().

EventQueue OmniEvents::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:

• ConsumerAdmin.h
• ConsumerAdmin.cc

---