#include <SequencePushConsumer.h>
Inheritance 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. |
|
|
|
|
|
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. |
|
Add request to a queue if necessary. for Sequence it's always necessary. Reimplemented from TAO_Notify_Consumer. |
|
Retrieve the ior of this peer.
Implements TAO_Notify_Peer. |
|
Init the Consumer.
|
|
Push a batch of events to this consumer.
Implements TAO_Notify_Consumer. |
|
Push <event> to this consumer.
Implements TAO_Notify_Consumer. |
|
Push <event> to this consumer.
Implements TAO_Notify_Consumer. |
|
on reconnect we need to move events from the old consumer to the new one Implements TAO_Notify_Consumer. |
|
TAO_Notify_Destroy_Callback methods.
Implements TAO_Notify_Peer. |
|
The Consumer.
|