OmniEvents::ConsumerAdmin_i Class Reference

#include <ConsumerAdmin.h>

Inheritance diagram for OmniEvents::ConsumerAdmin_i:
Inheritance graph
[legend]
Collaboration diagram for OmniEvents::ConsumerAdmin_i:
Collaboration graph
[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 
)
OmniEvents::ConsumerAdmin_i::~ConsumerAdmin_i (  )  [virtual]

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 (  ) 
CosEventChannelAdmin::ProxyPushSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_push_supplier (  ) 
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  ) 
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

Definition at line 88 of file ConsumerAdmin.h.

Referenced by ConsumerAdmin_i(), obtain_pull_supplier(), and reincarnate().


The documentation for this class was generated from the following files:

Generated on Mon Sep 28 05:10:19 2009 for OmniEvents by  doxygen 1.6.1