OmniEvents
OmniEvents::ConsumerAdmin_i Class Reference

#include <ConsumerAdmin.h>

Inheritance diagram for OmniEvents::ConsumerAdmin_i:
Collaboration diagram for OmniEvents::ConsumerAdmin_i:

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.
- Public Member Functions inherited from OmniEvents::Servant
virtual PortableServer::POA_ptr _default_POA ()
virtual ~Servant ()

Private Attributes

const EventChannel_i_channel
EventQueue _queue
ProxyPushSupplierManager_pushSupplier
ProxyPullSupplierManager_pullSupplier

Additional Inherited Members

- Protected Member Functions inherited from OmniEvents::Servant
 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.
- Protected Attributes inherited from OmniEvents::Servant
PortableServer::POA_var _poa

Detailed Description

Definition at line 54 of file ConsumerAdmin.h.

Constructor & Destructor Documentation

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

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

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
ProxyPushSupplierManager* OmniEvents::ConsumerAdmin_i::_pushSupplier
private
EventQueue OmniEvents::ConsumerAdmin_i::_queue
private

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