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

bool TAO_Notify_SequencePushConsumer::dispatch_from_queue	(	Request_Queue &	requests,
		ACE_Guard< TAO_SYNCH_MUTEX > &	ace_mon
	)			[virtual]

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.

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 CosNotification::EventBatch &

event

)

[virtual]

Push a batch of events to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_SequencePushConsumer::push

(

const CosNotification::StructuredEvent &

event

)

[virtual]

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_SequencePushConsumer::push

(

const CORBA::Any &

event

)

[virtual]

Push <event> 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

---