---

TAO_Notify_Consumer Class Reference

Astract Base class for wrapping consumer objects that connect to the EventChannel. More...

#include <Consumer.h>

Inheritance diagram for TAO_Notify_Consumer:

[legend]Collaboration diagram for TAO_Notify_Consumer:

[legend]List of all members.

Public Methods
	TAO_Notify_Consumer (TAO_Notify_ProxySupplier *proxy)
	Constuctor.
virtual	~TAO_Notify_Consumer ()
	Destructor.
TAO_Notify_ProxySupplier *	proxy_supplier (void)
	Access Specific Proxy.
virtual TAO_Notify_Proxy *	proxy (void)
	Access Base Proxy.
void	push (const TAO_Notify_Event *event ACE_ENV_ARG_DECL)
	Push <event> to this consumer.
void	push (const TAO_Notify_Event_var &event ACE_ENV_ARG_DECL)
	Push <event> to this consumer.
virtual void	push (const CORBA::Any &event ACE_ENV_ARG_DECL)=0
	Push <event> to this consumer.
virtual void	push (const CosNotification::StructuredEvent &event ACE_ENV_ARG_DECL)=0
	Push <event> to this consumer.
void	dispatch_pending (ACE_ENV_SINGLE_ARG_DECL)
	Dispatch the pending events.
CORBA::Boolean	is_suspended (void)
	Is the connection suspended?
void	suspend (ACE_ENV_SINGLE_ARG_DECL)
	Suspend Connection.
void	resume (ACE_ENV_SINGLE_ARG_DECL)
	Resume Connection.
Protected Methods
virtual void	dispatch_updates_i (const CosNotification::EventTypeSeq &added, const CosNotification::EventTypeSeq &removed ACE_ENV_ARG_DECL)
	Implementation of Peer specific dispatch_updates.
virtual void	push_i (const TAO_Notify_Event *event ACE_ENV_ARG_DECL)=0
	Push Implementation.
virtual void	push_i (const TAO_Notify_Event_var &event ACE_ENV_ARG_DECL)=0
	Push Implementation.
TAO_SYNCH_MUTEX *	proxy_lock (void)
	Get the shared Proxy Lock.
Protected Attributes
TAO_Notify_ProxySupplier *	proxy_
	The Proxy that we associate with.
TAO_Notify_Event_Collection *	event_collection_
	Events pending to be delivered.
CORBA::Boolean	is_suspended_
	Suspended Flag.
CosNotifyComm::NotifyPublish_var	publish_
	Interface that accepts offer_changes.

---

Detailed Description

Astract Base class for wrapping consumer objects that connect to the EventChannel.

---

Constructor & Destructor Documentation

TAO_Notify_Consumer::TAO_Notify_Consumer (  TAO_Notify_ProxySupplier *    proxy )

Constuctor.

TAO_Notify_Consumer::~TAO_Notify_Consumer (    )  [virtual]

Destructor.

---

Member Function Documentation

void TAO_Notify_Consumer::dispatch_pending (  ACE_ENV_SINGLE_ARG_DECL    )

Dispatch the pending events.

void TAO_Notify_Consumer::dispatch_updates_i (  const CosNotification::EventTypeSeq &    added, const CosNotification::EventTypeSeq &removed    ACE_ENV_ARG_DECL )  [protected, virtual]

Implementation of Peer specific dispatch_updates. Implements TAO_Notify_Peer.

CORBA::Boolean TAO_Notify_Consumer::is_suspended (  void    )

Is the connection suspended?

TAO_Notify_Proxy * TAO_Notify_Consumer::proxy (  void    )  [virtual]

Access Base Proxy. Implements TAO_Notify_Peer.

TAO_SYNCH_MUTEX* TAO_Notify_Consumer::proxy_lock (  void    )  [protected]

Get the shared Proxy Lock.

TAO_Notify_ProxySupplier* TAO_Notify_Consumer::proxy_supplier (  void    )

Access Specific Proxy.

virtual void TAO_Notify_Consumer::push (  const CosNotification::StructuredEvent &event    ACE_ENV_ARG_DECL )  [pure virtual]

Push <event> to this consumer.

virtual void TAO_Notify_Consumer::push (  const CORBA::Any &event    ACE_ENV_ARG_DECL )  [pure virtual]

Push <event> to this consumer.

void TAO_Notify_Consumer::push (  const TAO_Notify_Event_var &event    ACE_ENV_ARG_DECL )

Push <event> to this consumer.

void TAO_Notify_Consumer::push (  const TAO_Notify_Event *event    ACE_ENV_ARG_DECL )

Push <event> to this consumer.

virtual void TAO_Notify_Consumer::push_i (  const TAO_Notify_Event_var &event    ACE_ENV_ARG_DECL )  [protected, pure virtual]

Push Implementation.

virtual void TAO_Notify_Consumer::push_i (  const TAO_Notify_Event *event    ACE_ENV_ARG_DECL )  [protected, pure virtual]

Push Implementation.

void TAO_Notify_Consumer::resume (  ACE_ENV_SINGLE_ARG_DECL    )

Resume Connection.

void TAO_Notify_Consumer::suspend (  ACE_ENV_SINGLE_ARG_DECL    )

Suspend Connection.

---

Member Data Documentation

TAO_Notify_Event_Collection* TAO_Notify_Consumer::event_collection_ [protected]

Events pending to be delivered.

CORBA::Boolean TAO_Notify_Consumer::is_suspended_ [protected]

Suspended Flag.

TAO_Notify_ProxySupplier* TAO_Notify_Consumer::proxy_ [protected]

The Proxy that we associate with.

CosNotifyComm::NotifyPublish_var TAO_Notify_Consumer::publish_ [protected]

Interface that accepts offer_changes.

---

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

• Consumer.h
• Consumer.cpp

---