TAO_Notify_SequencePushConsumer Class Reference

#include <SequencePushConsumer.h>

Inheritance diagram for TAO_Notify_SequencePushConsumer:

[legend]Collaboration diagram for TAO_Notify_SequencePushConsumer:

[legend]List of all members.

Public Member Functions
	TAO_Notify_SequencePushConsumer (TAO_Notify_ProxySupplier *proxy)
virtual	~TAO_Notify_SequencePushConsumer ()
void	init (CosNotifyComm::SequencePushConsumer_ptr push_consumer ACE_ENV_ARG_DECL)
	Init the Consumer.
virtual bool	enqueue_if_necessary (TAO_Notify_Method_Request_Event *request ACE_ENV_ARG_DECL)
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 ACE_ENV_ARG_DECL)
	Push <event> to this consumer.
virtual void	push (const CosNotification::StructuredEvent &event ACE_ENV_ARG_DECL)
	Push <event> to this consumer.
virtual void	push (const CosNotification::EventBatch &event ACE_ENV_ARG_DECL)
	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 ACE_ENV_ARG_DECL)
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

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.

bool TAO_Notify_SequencePushConsumer::enqueue_if_necessary (  TAO_Notify_Method_Request_Event *request  ACE_ENV_ARG_DECL  )  [virtual]

Add request to a queue if necessary. for Sequence it's always necessary. Reimplemented from TAO_Notify_Consumer.

ACE_CString TAO_Notify_SequencePushConsumer::get_ior (  void   )  const [virtual]

Retrieve the ior of this peer. Implements TAO_Notify_Peer.

void TAO_Notify_SequencePushConsumer::init (  CosNotifyComm::SequencePushConsumer_ptr push_consumer  ACE_ENV_ARG_DECL  )

Init the Consumer.

virtual void TAO_Notify_SequencePushConsumer::push (  const CosNotification::EventBatch &event  ACE_ENV_ARG_DECL  )  [virtual]

Push a batch of events to this consumer. Implements TAO_Notify_Consumer.

virtual void TAO_Notify_SequencePushConsumer::push (  const CosNotification::StructuredEvent &event  ACE_ENV_ARG_DECL  )  [virtual]

Push <event> to this consumer. Implements TAO_Notify_Consumer.

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

Push <event> to this consumer. Implements TAO_Notify_Consumer.

void TAO_Notify_SequencePushConsumer::reconnect_from_consumer (  TAO_Notify_Consumer *old_consumer  ACE_ENV_ARG_DECL  )  [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]

TAO_Notify_Destroy_Callback methods. Implements TAO_Notify_Peer.

---

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:

• SequencePushConsumer.h
• SequencePushConsumer.cpp

---