TAO_CosNotification  2.0.8
Public Member Functions | Protected Member Functions | Protected Attributes | Private Member Functions
TAO_Notify_PushConsumer Class Reference

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

#include <PushConsumer.h>

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

List of all members.

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.


Member Function Documentation

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.

Implements TAO_Notify_Consumer.

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

Retrieve the ior of this peer.

Implements TAO_Notify_Peer.

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

Init.

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

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

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

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

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

Push a batch of events to this consumer.

Implements TAO_Notify_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

Implements TAO_Notify_Consumer.

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

TAO_Notify_Destroy_Callback methods.

Implements TAO_Notify_Peer.


Member Data Documentation

CosEventComm::PushConsumer_var TAO_Notify_PushConsumer::push_consumer_ [protected]

The Consumer.


The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines