TAO_EC_Default_ProxyPushConsumer Class Reference

implements RtecEventChannelAdmin::ProxyPushConsumer interface. More...

#include <EC_Default_ProxyConsumer.h>

Inheritance diagram for TAO_EC_Default_ProxyPushConsumer:

Collaboration diagram for TAO_EC_Default_ProxyPushConsumer:

Public Member Functions
	TAO_EC_Default_ProxyPushConsumer (TAO_EC_Event_Channel_Base *event_channel)
	Constructor...
virtual	~TAO_EC_Default_ProxyPushConsumer ()
	Destructor...
virtual void	activate (RtecEventChannelAdmin::ProxyPushConsumer_ptr &proxy)
	Activate in the POA.
virtual void	connect_push_supplier (RtecEventComm::PushSupplier_ptr push_supplier, const RtecEventChannelAdmin::SupplierQOS &qos)
virtual void	push (const RtecEventComm::EventSet &event)
virtual void	disconnect_push_consumer ()
	Disconnect this from.
virtual PortableServer::POA_ptr	_default_POA ()
virtual void	_add_ref ()
virtual void	_remove_ref ()
Public Member Functions inherited from TAO_EC_ProxyPushConsumer
	TAO_EC_ProxyPushConsumer (TAO_EC_Event_Channel_Base *event_channel)
	constructor...
virtual	~TAO_EC_ProxyPushConsumer ()
	destructor...
virtual void	deactivate ()
	Deactivate from the POA.
CORBA::Boolean	is_connected () const
	Return false if no supplier is connected...
RtecEventComm::PushSupplier_ptr	supplier () const
const RtecEventChannelAdmin::SupplierQOS &	publications () const
	The QoS (subscription) used to connect to the EC.
CORBA::Boolean	supplier_non_existent (CORBA::Boolean_out disconnected)
virtual void	connected (TAO_EC_ProxyPushSupplier *supplier)
virtual void	reconnected (TAO_EC_ProxyPushSupplier *supplier)
virtual void	disconnected (TAO_EC_ProxyPushSupplier *supplier)
virtual void	connected (TAO_EC_ProxyPushConsumer *consumer)
virtual void	reconnected (TAO_EC_ProxyPushConsumer *consumer)
virtual void	disconnected (TAO_EC_ProxyPushConsumer *consumer)
virtual void	shutdown ()
	The event channel is shutting down.
const RtecEventChannelAdmin::SupplierQOS &	publications_i () const
CORBA::ULong	_incr_refcnt ()
	Increment and decrement the reference count.
CORBA::ULong	_decr_refcnt ()

Private Member Functions
virtual PortableServer::ObjectId	object_id ()

Additional Inherited Members
Public Types inherited from TAO_EC_ProxyPushConsumer
typedef RtecEventChannelAdmin::ProxyPushConsumer	Interface
typedef RtecEventChannelAdmin::ProxyPushConsumer_var	_var_type
typedef RtecEventChannelAdmin::ProxyPushConsumer_ptr	_ptr_type
Protected Member Functions inherited from TAO_EC_ProxyPushConsumer
void	supplier (RtecEventComm::PushSupplier_ptr supplier)
void	supplier_i (RtecEventComm::PushSupplier_ptr supplier)
CORBA::Boolean	is_connected_i () const
	The private version (without locking) of is_connected().
TAO_EC_Supplier_Filter *	filter_i () const
	Return the current filter, assumes the locks are held.
void	cleanup_i ()
	Release the filter and the supplier.
Protected Attributes inherited from TAO_EC_ProxyPushConsumer
TAO_EC_Event_Channel_Base *	event_channel_
	The supplier admin, used for activation and memory management.
ACE_Lock *	lock_
	The locking strategy.
CORBA::ULong	ec_refcount_
	The reference count.
RtecEventComm::PushSupplier_var	supplier_
	The supplier....
bool	connected_
RtecEventChannelAdmin::SupplierQOS	qos_
	The publication and QoS information...
PortableServer::POA_var	default_POA_
	Store the default POA.
TAO_EC_Supplier_Filter *	filter_
	The strategy to do filtering close to the supplier.

Detailed Description

implements RtecEventChannelAdmin::ProxyPushConsumer interface.

Constructor & Destructor Documentation

TAO_EC_Default_ProxyPushConsumer()

TAO_EC_Default_ProxyPushConsumer::TAO_EC_Default_ProxyPushConsumer

(

TAO_EC_Event_Channel_Base *

event_channel

)

Constructor...

~TAO_EC_Default_ProxyPushConsumer()

TAO_EC_Default_ProxyPushConsumer::~TAO_EC_Default_ProxyPushConsumer ( )

virtual

Destructor...

Member Function Documentation

_add_ref()

void TAO_EC_Default_ProxyPushConsumer::_add_ref ( )

virtual

_default_POA()

PortableServer::POA_ptr TAO_EC_Default_ProxyPushConsumer::_default_POA ( )

virtual

_remove_ref()

void TAO_EC_Default_ProxyPushConsumer::_remove_ref ( )

virtual

activate()

void TAO_EC_Default_ProxyPushConsumer::activate ( RtecEventChannelAdmin::ProxyPushConsumer_ptr & proxy )

virtual

Activate in the POA.

Implements TAO_EC_ProxyPushConsumer.

connect_push_supplier()

void TAO_EC_Default_ProxyPushConsumer::connect_push_supplier ( RtecEventComm::PushSupplier_ptr push_supplier, const RtecEventChannelAdmin::SupplierQOS & qos )

virtual

disconnect_push_consumer()

void TAO_EC_Default_ProxyPushConsumer::disconnect_push_consumer ( )

virtual

Disconnect this from.

Implements TAO_EC_ProxyPushConsumer.

Reimplemented in TAO_EC_TPC_ProxyPushConsumer.

object_id()

PortableServer::ObjectId TAO_EC_Default_ProxyPushConsumer::object_id ( )

privatevirtual

Implements TAO_EC_ProxyPushConsumer.

push()

void TAO_EC_Default_ProxyPushConsumer::push ( const RtecEventComm::EventSet & event )

virtual

---

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

• EC_Default_ProxyConsumer.h
• EC_Default_ProxyConsumer.cpp