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

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

#include <StructuredPushConsumer.h>

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

List of all members.

Public Member Functions

 TAO_Notify_StructuredPushConsumer (TAO_Notify_ProxySupplier *proxy)
 Constructor.
void init (CosNotifyComm::StructuredPushConsumer_ptr push_consumer)
 Init the Consumer.
virtual ~TAO_Notify_StructuredPushConsumer ()
 Destructor.
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

CosNotifyComm::StructuredPushConsumer_var push_consumer_
 The Consumer.

Private Member Functions

virtual void release (void)
 Release.

Private Attributes

int connection_valid
 Connection valid flag.

Detailed Description

Wrapper for the StructuredPushConsumer that connect to the EventChannel.


Constructor & Destructor Documentation

TAO_Notify_StructuredPushConsumer::TAO_Notify_StructuredPushConsumer ( TAO_Notify_ProxySupplier proxy)

Constructor.

TAO_Notify_StructuredPushConsumer::~TAO_Notify_StructuredPushConsumer ( ) [virtual]

Destructor.


Member Function Documentation

CORBA::Object_ptr TAO_Notify_StructuredPushConsumer::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_StructuredPushConsumer::get_ior ( void  ) const [virtual]

Retrieve the ior of this peer.

Implements TAO_Notify_Peer.

void TAO_Notify_StructuredPushConsumer::init ( CosNotifyComm::StructuredPushConsumer_ptr  push_consumer)

Init the Consumer.

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

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

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

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

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

Push a batch of events to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_StructuredPushConsumer::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_StructuredPushConsumer::release ( void  ) [private, virtual]

Release.

Implements TAO_Notify_Peer.


Member Data Documentation

Connection valid flag.

CosNotifyComm::StructuredPushConsumer_var TAO_Notify_StructuredPushConsumer::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