TAO_CosEvent 4.0.0
|
ConsumerAdmin. More...
#include <CEC_ConsumerAdmin.h>
Public Member Functions | |
TAO_CEC_ConsumerAdmin (TAO_CEC_EventChannel *event_channel) | |
virtual | ~TAO_CEC_ConsumerAdmin () |
Destructor... | |
void | for_each (TAO_ESF_Worker< TAO_CEC_ProxyPushSupplier > *worker) |
For each elements call <worker->work()>. | |
void | for_each (TAO_ESF_Worker< TAO_CEC_ProxyPullSupplier > *worker) |
void | push (const CORBA::Any &event) |
Push the event to all the consumers. | |
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 () |
virtual CosEventChannelAdmin::ProxyPushSupplier_ptr | obtain_push_supplier () |
virtual CosEventChannelAdmin::ProxyPullSupplier_ptr | obtain_pull_supplier () |
virtual PortableServer::POA_ptr | _default_POA () |
Private Attributes | |
TAO_CEC_EventChannel * | event_channel_ |
The Event Channel we belong to. | |
PortableServer::POA_var | default_POA_ |
Store the default POA. | |
TAO_ESF_Proxy_Admin< TAO_CEC_EventChannel, TAO_CEC_ProxyPushSupplier, CosEventChannelAdmin::ProxyPushSupplier > | push_admin_ |
Implement the push side of this class. | |
TAO_ESF_Proxy_Admin< TAO_CEC_EventChannel, TAO_CEC_ProxyPullSupplier, CosEventChannelAdmin::ProxyPullSupplier > | pull_admin_ |
Implement the pull side of this class. | |
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
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.
|
virtual |
Destructor...
|
virtual |
|
virtual |
|
virtual |
Used to inform the EC that a Supplier has connected or disconnected from it.
|
virtual |
|
virtual |
void TAO_CEC_ConsumerAdmin::for_each | ( | TAO_ESF_Worker< TAO_CEC_ProxyPullSupplier > * | worker | ) |
void TAO_CEC_ConsumerAdmin::for_each | ( | TAO_ESF_Worker< TAO_CEC_ProxyPushSupplier > * | worker | ) |
For each elements call <worker->work()>.
|
virtual |
|
virtual |
void TAO_CEC_ConsumerAdmin::push | ( | const CORBA::Any & | event | ) |
Push the event to all the consumers.
|
virtual |
|
virtual |
|
virtual |
The event channel is shutting down, inform all the consumers of this
|
private |
Store the default POA.
|
private |
The Event Channel we belong to.
|
private |
Implement the pull side of this class.
|
private |
Implement the push side of this class.