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 
)

Definition at line 50 of file ConsumerAdmin.cc.

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

Definition at line 76 of file ConsumerAdmin.cc.


Member Function Documentation

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


Member Data Documentation

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


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

Generated by  doxygen 1.6.2