TAO_Notify_SequencePushConsumer Class Reference
#include <SequencePushConsumer.h>
Inheritance diagram for TAO_Notify_SequencePushConsumer:
Collaboration diagram for TAO_Notify_SequencePushConsumer:
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 Attributes | |
| CosNotifyComm::SequencePushConsumer_var | push_consumer_ |
| The Consumer. | |
Private Member Functions | |
| virtual void | release (void) |
| TAO_Notify_Destroy_Callback methods. | |
Constructor & Destructor Documentation
| TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Notify_SequencePushConsumer::TAO_Notify_SequencePushConsumer | ( | TAO_Notify_ProxySupplier * | proxy | ) |
| TAO_Notify_SequencePushConsumer::~TAO_Notify_SequencePushConsumer | ( | ) | [virtual] |
Member Function Documentation
| void TAO_Notify_SequencePushConsumer::init | ( | CosNotifyComm::SequencePushConsumer_ptr | push_consumer | ) |
Init the 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.
| 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.
- Returns:
- false if delivery failed and the request(s) cannot be discarded.
Reimplemented from TAO_Notify_Consumer.
| void TAO_Notify_SequencePushConsumer::push | ( | const CORBA::Any & | event | ) | [virtual] |
| void TAO_Notify_SequencePushConsumer::push | ( | const CosNotification::StructuredEvent & | event | ) | [virtual] |
| void TAO_Notify_SequencePushConsumer::push | ( | const CosNotification::EventBatch & | event | ) | [virtual] |
| ACE_CString TAO_Notify_SequencePushConsumer::get_ior | ( | void | ) | const [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] |
Member Data Documentation
CosNotifyComm::SequencePushConsumer_var TAO_Notify_SequencePushConsumer::push_consumer_ [protected] |
The Consumer.
The documentation for this class was generated from the following files:
