TAO_CosEvent  2.5.3
Public Member Functions | Private Attributes | List of all members
TAO_CEC_ConsumerAdmin Class Reference

ConsumerAdmin. More...

#include <CEC_ConsumerAdmin.h>

Inheritance diagram for TAO_CEC_ConsumerAdmin:
Inheritance graph
[legend]
Collaboration diagram for TAO_CEC_ConsumerAdmin:
Collaboration graph
[legend]

Public Member Functions

 TAO_CEC_ConsumerAdmin (TAO_CEC_EventChannel *event_channel)
 
virtual ~TAO_CEC_ConsumerAdmin (void)
 Destructor... More...
 
void for_each (TAO_ESF_Worker< TAO_CEC_ProxyPushSupplier > *worker)
 For each elements call <worker->work()>. More...
 
void for_each (TAO_ESF_Worker< TAO_CEC_ProxyPullSupplier > *worker)
 
void push (const CORBA::Any &event)
 Push the event to all the consumers. More...
 
virtual void connected (TAO_CEC_ProxyPushSupplier *)
 
virtual void reconnected (TAO_CEC_ProxyPushSupplier *)
 
virtual void disconnected (TAO_CEC_ProxyPushSupplier *)
 
virtual void connected (TAO_CEC_ProxyPullSupplier *)
 
virtual void reconnected (TAO_CEC_ProxyPullSupplier *)
 
virtual void disconnected (TAO_CEC_ProxyPullSupplier *)
 
virtual void shutdown (void)
 
virtual CosEventChannelAdmin::ProxyPushSupplier_ptr obtain_push_supplier (void)
 
virtual CosEventChannelAdmin::ProxyPullSupplier_ptr obtain_pull_supplier (void)
 
virtual PortableServer::POA_ptr _default_POA (void)
 

Private Attributes

TAO_CEC_EventChannelevent_channel_
 The Event Channel we belong to. More...
 
PortableServer::POA_var default_POA_
 Store the default POA. More...
 
TAO_ESF_Proxy_Admin< TAO_CEC_EventChannel, TAO_CEC_ProxyPushSupplier, CosEventChannelAdmin::ProxyPushSupplierpush_admin_
 Implement the push side of this class. More...
 
TAO_ESF_Proxy_Admin< TAO_CEC_EventChannel, TAO_CEC_ProxyPullSupplier, CosEventChannelAdmin::ProxyPullSupplierpull_admin_
 Implement the pull side of this class. More...
 

Detailed Description

ConsumerAdmin.

Implements the ConsumerAdmin interface, i.e. the factory for ProxyPushSupplier objects. = MEMORY MANAGEMENT It does not assume ownership of the TAO_CEC_EventChannel object; but it does assume ownership of the TAO_CEC_ProxyPushSupplier_Set object. = LOCKING No provisions for locking, access must be serialized externally. = TODO

Constructor & Destructor Documentation

◆ TAO_CEC_ConsumerAdmin()

TAO_CEC_ConsumerAdmin::TAO_CEC_ConsumerAdmin ( TAO_CEC_EventChannel event_channel)

Constructor. If <supplier_set> is nil then it builds one using the event_channel argument. In any case it assumes ownership.

◆ ~TAO_CEC_ConsumerAdmin()

TAO_CEC_ConsumerAdmin::~TAO_CEC_ConsumerAdmin ( void  )
virtual

Destructor...

Member Function Documentation

◆ _default_POA()

PortableServer::POA_ptr TAO_CEC_ConsumerAdmin::_default_POA ( void  )
virtual

◆ connected() [1/2]

void TAO_CEC_ConsumerAdmin::connected ( TAO_CEC_ProxyPushSupplier supplier)
virtual

Used to inform the EC that a Supplier has connected or disconnected from it.

◆ connected() [2/2]

void TAO_CEC_ConsumerAdmin::connected ( TAO_CEC_ProxyPullSupplier supplier)
virtual

◆ disconnected() [1/2]

void TAO_CEC_ConsumerAdmin::disconnected ( TAO_CEC_ProxyPushSupplier supplier)
virtual

◆ disconnected() [2/2]

void TAO_CEC_ConsumerAdmin::disconnected ( TAO_CEC_ProxyPullSupplier supplier)
virtual

◆ for_each() [1/2]

void TAO_CEC_ConsumerAdmin::for_each ( TAO_ESF_Worker< TAO_CEC_ProxyPushSupplier > *  worker)

For each elements call <worker->work()>.

◆ for_each() [2/2]

void TAO_CEC_ConsumerAdmin::for_each ( TAO_ESF_Worker< TAO_CEC_ProxyPullSupplier > *  worker)

◆ obtain_pull_supplier()

CosEventChannelAdmin::ProxyPullSupplier_ptr TAO_CEC_ConsumerAdmin::obtain_pull_supplier ( void  )
virtual

◆ obtain_push_supplier()

CosEventChannelAdmin::ProxyPushSupplier_ptr TAO_CEC_ConsumerAdmin::obtain_push_supplier ( void  )
virtual

◆ push()

void TAO_CEC_ConsumerAdmin::push ( const CORBA::Any &  event)

Push the event to all the consumers.

◆ reconnected() [1/2]

void TAO_CEC_ConsumerAdmin::reconnected ( TAO_CEC_ProxyPushSupplier supplier)
virtual

◆ reconnected() [2/2]

void TAO_CEC_ConsumerAdmin::reconnected ( TAO_CEC_ProxyPullSupplier supplier)
virtual

◆ shutdown()

void TAO_CEC_ConsumerAdmin::shutdown ( void  )
virtual

The event channel is shutting down, inform all the consumers of this

Member Data Documentation

◆ default_POA_

PortableServer::POA_var TAO_CEC_ConsumerAdmin::default_POA_
private

Store the default POA.

◆ event_channel_

TAO_CEC_EventChannel* TAO_CEC_ConsumerAdmin::event_channel_
private

The Event Channel we belong to.

◆ pull_admin_

Implement the pull side of this class.

◆ push_admin_

Implement the push side of this class.


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