#include <SequencePushConsumer.h>
Public Member Functions | |
TAO_Notify_SequencePushConsumer (TAO_Notify_ProxySupplier *proxy) | |
virtual | ~TAO_Notify_SequencePushConsumer () |
void | init (CosNotifyComm::SequencePushConsumer_ptr push_consumer) |
Init the Consumer. | |
virtual bool | enqueue_if_necessary (TAO_Notify_Method_Request_Event *request) |
virtual bool | dispatch_from_queue (Request_Queue &requests, ACE_Guard< TAO_SYNCH_MUTEX > &ace_mon) |
Attempt to dispatch event from a queue. | |
virtual void | push (const CORBA::Any &event) |
Push <event> to this consumer. | |
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::SequencePushConsumer_var | push_consumer_ |
The Consumer. | |
Private Member Functions | |
virtual void | release (void) |
TAO_Notify_Destroy_Callback methods. |
TAO_Notify_SequencePushConsumer::TAO_Notify_SequencePushConsumer | ( | TAO_Notify_ProxySupplier * | proxy | ) |
TAO_Notify_SequencePushConsumer::~TAO_Notify_SequencePushConsumer | ( | ) | [virtual] |
bool TAO_Notify_SequencePushConsumer::dispatch_from_queue | ( | Request_Queue & | requests, | |
ACE_Guard< TAO_SYNCH_MUTEX > & | ace_mon | |||
) | [virtual] |
Attempt to dispatch event from a queue.
Called by dispatch_pending. Deliver one or more events to the Consumer. If delivery fails, events are left in the queue (or discarded depending on QoS parameters.) Undelivered, undiscarded requests are left at the front of the queue. Overridden in sequence consumer to dispatch as an EventBatch.
Reimplemented from TAO_Notify_Consumer.
bool TAO_Notify_SequencePushConsumer::enqueue_if_necessary | ( | TAO_Notify_Method_Request_Event * | request | ) | [virtual] |
Add request to a queue if necessary. for Sequence it's always necessary.
Reimplemented from TAO_Notify_Consumer.
CORBA::Object_ptr TAO_Notify_SequencePushConsumer::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_SequencePushConsumer::get_ior | ( | void | ) | const [virtual] |
void TAO_Notify_SequencePushConsumer::init | ( | CosNotifyComm::SequencePushConsumer_ptr | push_consumer | ) |
Init the Consumer.
void TAO_Notify_SequencePushConsumer::push | ( | const CosNotification::EventBatch & | event | ) | [virtual] |
void TAO_Notify_SequencePushConsumer::push | ( | const CosNotification::StructuredEvent & | event | ) | [virtual] |
void TAO_Notify_SequencePushConsumer::push | ( | const CORBA::Any & | event | ) | [virtual] |
void TAO_Notify_SequencePushConsumer::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_SequencePushConsumer::release | ( | void | ) | [private, virtual] |
CosNotifyComm::SequencePushConsumer_var TAO_Notify_SequencePushConsumer::push_consumer_ [protected] |
The Consumer.