TAO_CosNotification
2.0.8
|
Wrapper for the StructuredPushConsumer that connect to the EventChannel. More...
#include <StructuredPushConsumer.h>
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. |
Wrapper for the StructuredPushConsumer that connect to the EventChannel.
TAO_Notify_StructuredPushConsumer::TAO_Notify_StructuredPushConsumer | ( | TAO_Notify_ProxySupplier * | proxy | ) |
Constructor.
TAO_Notify_StructuredPushConsumer::~TAO_Notify_StructuredPushConsumer | ( | ) | [virtual] |
Destructor.
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.
int TAO_Notify_StructuredPushConsumer::connection_valid [private] |
Connection valid flag.
CosNotifyComm::StructuredPushConsumer_var TAO_Notify_StructuredPushConsumer::push_consumer_ [protected] |
The Consumer.