TAO_Notify_SequencePushConsumer Class Reference

#include <SequencePushConsumer.h>

Inheritance diagram for TAO_Notify_SequencePushConsumer:

Collaboration diagram for TAO_Notify_SequencePushConsumer:

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)
	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.
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.

---

Constructor & Destructor Documentation

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

)

[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]

Retrieve the ior of this peer.

Implements TAO_Notify_Peer.

void TAO_Notify_SequencePushConsumer::init

(

CosNotifyComm::SequencePushConsumer_ptr

push_consumer

)

Init the Consumer.

void TAO_Notify_SequencePushConsumer::push

(

const CORBA::Any &

event

)

[virtual]

Push event to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_SequencePushConsumer::push

(

const CosNotification::StructuredEvent &

event

)

[virtual]

Push event.

Implements TAO_Notify_Consumer.

void TAO_Notify_SequencePushConsumer::push

(

const CosNotification::EventBatch &

event

)

[virtual]

Push a batch of events to this consumer.

Implements TAO_Notify_Consumer.

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]

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