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

◆ ConsumerAdmin_i()

◆ ~ConsumerAdmin_i()

OmniEvents::ConsumerAdmin_i::~ConsumerAdmin_i ( )
virtual

Member Function Documentation

◆ disconnect()

void OmniEvents::ConsumerAdmin_i::disconnect ( )

◆ obtain_pull_supplier()

CosEventChannelAdmin::ProxyPullSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_pull_supplier ( )

◆ obtain_push_supplier()

CosEventChannelAdmin::ProxyPushSupplier_ptr OmniEvents::ConsumerAdmin_i::obtain_push_supplier ( )

◆ output()

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

◆ reincarnate()

void OmniEvents::ConsumerAdmin_i::reincarnate ( const PersistNode node)

◆ send() [1/2]

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

◆ send() [2/2]

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

◆ _channel

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

◆ _pullSupplier

ProxyPullSupplierManager* OmniEvents::ConsumerAdmin_i::_pullSupplier
private

◆ _pushSupplier

ProxyPushSupplierManager* OmniEvents::ConsumerAdmin_i::_pushSupplier
private

◆ _queue

EventQueue OmniEvents::ConsumerAdmin_i::_queue
private

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