Wrapper for the PushConsumer that connect to the EventChannel. More...

#include <PushConsumer.h>

Inheritance diagram for TAO_Notify_PushConsumer:

Collaboration diagram for TAO_Notify_PushConsumer:

Public Member Functions
	TAO_Notify_PushConsumer (TAO_Notify_ProxySupplier *proxy)
	Constructor.
virtual	~TAO_Notify_PushConsumer ()
	Destructor.
void	init (CosEventComm::PushConsumer_ptr push_consumer)
	Init.
virtual void	push (const CORBA::Any &event)
virtual void	push (const CosNotification::StructuredEvent &event)
	Push <event> to this consumer.
virtual void	push (const CosNotification::EventBatch &event)
	Push a batch of events to this consumer.
virtual ACE_CString	get_ior (void) const
	Retrieve the ior of this peer.
virtual void	reconnect_from_consumer (TAO_Notify_Consumer *old_consumer)
Protected Member Functions
virtual CORBA::Object_ptr	get_consumer (void)
Protected Attributes
CosEventComm::PushConsumer_var	push_consumer_
	The Consumer.
Private Member Functions
virtual void	release (void)
	TAO_Notify_Destroy_Callback methods.

Detailed Description

Wrapper for the PushConsumer that connect to the EventChannel.

Constructor & Destructor Documentation

TAO_Notify_PushConsumer::TAO_Notify_PushConsumer ( TAO_Notify_ProxySupplier * proxy )

Constructor.

TAO_Notify_PushConsumer::~TAO_Notify_PushConsumer ( ) [virtual]

Destructor.

CORBA::Object_ptr TAO_Notify_PushConsumer::get_consumer ( void ) [protected, virtual]

This method is called by the is_alive() method. It should provide the connected consumer or nil if there is none.

ACE_CString TAO_Notify_PushConsumer::get_ior ( void ) const [virtual]

Retrieve the ior of this peer.

void TAO_Notify_PushConsumer::init ( CosEventComm::PushConsumer_ptr push_consumer )

Init.

void TAO_Notify_PushConsumer::push ( const CosNotification::EventBatch & event ) [virtual]

Push a batch of events to this consumer.

void TAO_Notify_PushConsumer::push ( const CORBA::Any & event ) [virtual]

Push <event> to this consumer.

void TAO_Notify_PushConsumer::push ( const CosNotification::StructuredEvent & event ) [virtual]

Push <event> to this consumer.

void TAO_Notify_PushConsumer::reconnect_from_consumer ( TAO_Notify_Consumer * old_consumer ) [virtual]

on reconnect we need to move events from the old consumer to the new one

void TAO_Notify_PushConsumer::release ( void ) [private, virtual]

TAO_Notify_Destroy_Callback methods.

CosEventComm::PushConsumer_var TAO_Notify_PushConsumer::push_consumer_ [protected]

The Consumer.

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