OmniEvents

OmniEvents::ConsumerAdmin_i Class Reference

#include <ConsumerAdmin.h>

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

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 58 of file ConsumerAdmin.cc.

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

Definition at line 84 of file ConsumerAdmin.cc.


Member Function Documentation

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.


Member Data Documentation

Definition at line 88 of file ConsumerAdmin.h.

Definition at line 89 of file ConsumerAdmin.h.

Referenced by reincarnate().


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