TAO_Notify_Method_Request_Dispatch_Queueable Class Reference

Dispatchs an event to a proxy supplier. More...

#include <Method_Request_Dispatch.h>

Inheritance diagram for TAO_Notify_Method_Request_Dispatch_Queueable:

Collaboration diagram for TAO_Notify_Method_Request_Dispatch_Queueable:

List of all members.

Public Member Functions
	TAO_Notify_Method_Request_Dispatch_Queueable (const TAO_Notify_Method_Request_Event &request, TAO_Notify_Event::Ptr &event, TAO_Notify_ProxySupplier *proxy_supplier, bool filtering)
	TAO_Notify_Method_Request_Dispatch_Queueable (const TAO_Notify::Delivery_Request_Ptr &request, TAO_Notify_ProxySupplier *proxy_supplier, bool filtering)
virtual	~TAO_Notify_Method_Request_Dispatch_Queueable ()
	Destructor.
virtual int	execute (void)
	Execute the Request.
Public Member Functions inherited from TAO_Notify_Method_Request_Dispatch
	TAO_Notify_Method_Request_Dispatch (const TAO_Notify_Event *event, TAO_Notify_ProxySupplier *proxy_supplier, bool filtering)
	Constuct from event.
	TAO_Notify_Method_Request_Dispatch (const TAO_Notify::Delivery_Request_Ptr &delivery, TAO_Notify_ProxySupplier *proxy_supplier, bool filtering)
	Construct from a delivery rquest.
	TAO_Notify_Method_Request_Dispatch (const TAO_Notify_Method_Request_Event &request, const TAO_Notify_Event *event, TAO_Notify_ProxySupplier *proxy_supplier, bool filtering)
virtual	~TAO_Notify_Method_Request_Dispatch ()
	Destructor.
Public Member Functions inherited from TAO_Notify_Method_Request_Event
	TAO_Notify_Method_Request_Event (const TAO_Notify_Event *)
	Construct from event.
	TAO_Notify_Method_Request_Event (const TAO_Notify::Delivery_Request_Ptr &delivery_request)
	Construct from a delivery request.
	TAO_Notify_Method_Request_Event (const TAO_Notify_Method_Request_Event &rhs, const TAO_Notify_Event *event)
virtual	~TAO_Notify_Method_Request_Event ()
	Destructor.
const TAO_Notify_Event *	event () const
void	complete ()
unsigned long	sequence ()
bool	should_retry ()
Public Member Functions inherited from TAO_Notify_Method_Request_Queueable
	TAO_Notify_Method_Request_Queueable ()
	TAO_Notify_Method_Request_Queueable (const TAO_Notify_Event *event)
virtual TAO_Notify_Method_Request_Queueable *	copy (void)
void	init (const TAO_Notify_Event *event)
const ACE_Time_Value &	creation_time (void) const
	The creation time of the event to which this request corresponds.
Public Member Functions inherited from ACE_Message_Block
	ACE_Message_Block (ACE_Allocator *message_block_allocator=0)
	ACE_Message_Block (ACE_Data_Block *data_block, Message_Flags flags=0, ACE_Allocator *message_block_allocator=0)
	ACE_Message_Block (const char *data, size_t size=0, unsigned long priority=ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY)
	ACE_Message_Block (size_t size, ACE_Message_Type type=MB_DATA, ACE_Message_Block *cont=0, const char *data=0, ACE_Allocator *allocator_strategy=0, ACE_Lock *locking_strategy=0, unsigned long priority=ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY, const ACE_Time_Value &execution_time=ACE_Time_Value::zero, const ACE_Time_Value &deadline_time=ACE_Time_Value::max_time, ACE_Allocator *data_block_allocator=0, ACE_Allocator *message_block_allocator=0)
	ACE_Message_Block (const ACE_Message_Block &mb, size_t align)
int	init (const char *data, size_t size=0)
int	init (size_t size, ACE_Message_Type type=MB_DATA, ACE_Message_Block *cont=0, const char *data=0, ACE_Allocator *allocator_strategy=0, ACE_Lock *locking_strategy=0, unsigned long priority=ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY, const ACE_Time_Value &execution_time=ACE_Time_Value::zero, const ACE_Time_Value &deadline_time=ACE_Time_Value::max_time, ACE_Allocator *data_block_allocator=0, ACE_Allocator *message_block_allocator=0)
virtual	~ACE_Message_Block (void)
ACE_Message_Type	msg_type (void) const
void	msg_type (ACE_Message_Type type)
int	is_data_msg (void) const
ACE_Message_Type	msg_class (void) const
Message_Flags	set_flags (Message_Flags more_flags)
Message_Flags	clr_flags (Message_Flags less_flags)
Message_Flags	flags (void) const
Message_Flags	set_self_flags (ACE_Message_Block::Message_Flags more_flags)
Message_Flags	clr_self_flags (ACE_Message_Block::Message_Flags less_flags)
Message_Flags	self_flags (void) const
unsigned long	msg_priority (void) const
void	msg_priority (unsigned long priority)
const ACE_Time_Value &	msg_execution_time (void) const
void	msg_execution_time (const ACE_Time_Value &et)
const ACE_Time_Value &	msg_deadline_time (void) const
void	msg_deadline_time (const ACE_Time_Value &dt)
virtual ACE_Message_Block *	clone (Message_Flags mask=0) const
virtual ACE_Message_Block *	duplicate (void) const
virtual ACE_Message_Block *	release (void)
int	copy (const char *buf, size_t n)
int	copy (const char *buf)
int	crunch (void)
void	reset (void)
void	access_allocators (ACE_Allocator *&allocator_strategy, ACE_Allocator *&data_block_allocator, ACE_Allocator *&message_block_allocator)
void	reset_allocators (ACE_Allocator *allocator_strategy=0, ACE_Allocator *data_block_allocator=0, ACE_Allocator *message_block_allocator=0)
char *	base (void) const
void	base (char *data, size_t size, Message_Flags=DONT_DELETE)
char *	end (void) const
char *	mark (void) const
char *	rd_ptr (void) const
void	rd_ptr (char *ptr)
void	rd_ptr (size_t n)
char *	wr_ptr (void) const
void	wr_ptr (char *ptr)
void	wr_ptr (size_t n)
ACE_Data_Block *	data_block (void) const
void	data_block (ACE_Data_Block *)
ACE_Data_Block *	replace_data_block (ACE_Data_Block *)
ACE_Message_Block *	cont (void) const
void	cont (ACE_Message_Block *)
ACE_Message_Block *	next (void) const
void	next (ACE_Message_Block *)
ACE_Message_Block *	prev (void) const
void	prev (ACE_Message_Block *)
ACE_Lock *	locking_strategy (void)
ACE_Lock *	locking_strategy (ACE_Lock *)
int	reference_count (void) const
void	dump (void) const
size_t	length (void) const
void	length (size_t n)
size_t	total_length (void) const
size_t	total_size (void) const
void	total_size_and_length (size_t &mb_size, size_t &mb_length) const
size_t	size (void) const
int	size (size_t length)
size_t	total_capacity (void) const
size_t	capacity (void) const
size_t	space (void) const
Public Member Functions inherited from TAO_Notify_Method_Request
virtual	~TAO_Notify_Method_Request (void)
	Destructor.

Private Attributes
TAO_Notify_Event::Ptr	event_var_
TAO_Notify_ProxySupplier::Ptr	proxy_guard_

Additional Inherited Members
Public Types inherited from TAO_Notify_Method_Request_Dispatch
enum	{ persistence_code = 1 }
	an arbitrary code (Octet) to identify this delivery method type in persistent storage More...
Public Types inherited from TAO_Notify_Method_Request_Queueable
enum	{ PRIORITY_BASE = 32768 }
Public Types inherited from ACE_Message_Block
typedef int	ACE_Message_Type
typedef unsigned long	Message_Flags
Static Public Member Functions inherited from TAO_Notify_Method_Request_Dispatch
static TAO_Notify_Method_Request_Dispatch_Queueable *	unmarshal (TAO_Notify::Delivery_Request_Ptr &delivery_request, TAO_Notify_EventChannelFactory &ecf, TAO_InputCDR &cdr)
	Static method used to reconstruct a Method Request Dispatch.
Protected Member Functions inherited from TAO_Notify_Method_Request_Dispatch
int	execute_i (void)
	Execute the dispatch operation.
Protected Attributes inherited from TAO_Notify_Method_Request_Dispatch
TAO_Notify_ProxySupplier::Ptr	proxy_supplier_
	The Proxy.
bool	filtering_
	Flag is true if we want to do filtering else false.
Protected Attributes inherited from TAO_Notify_Method_Request_Event
const TAO_Notify_Event *	event_
	The Event.
TAO_Notify::Delivery_Request_Ptr	delivery_request_
	Pointer to the routing slip's delivery request (if any)

---

Detailed Description

Dispatchs an event to a proxy supplier.

---

Constructor & Destructor Documentation

TAO_Notify_Method_Request_Dispatch_Queueable::TAO_Notify_Method_Request_Dispatch_Queueable	(	const TAO_Notify_Method_Request_Event &	request,
		TAO_Notify_Event::Ptr &	event,
		TAO_Notify_ProxySupplier *	proxy_supplier,
		bool	filtering
	)

Construct construct from another method request+event event is passed separately because we may be using a copy of the one in the previous method request

TAO_Notify_Method_Request_Dispatch_Queueable::TAO_Notify_Method_Request_Dispatch_Queueable	(	const TAO_Notify::Delivery_Request_Ptr &	request,
		TAO_Notify_ProxySupplier *	proxy_supplier,
		bool	filtering
	)

Constuct construct from Delivery Request should ONLY be used by unmarshall

TAO_Notify_Method_Request_Dispatch_Queueable::~TAO_Notify_Method_Request_Dispatch_Queueable ( )

virtual

Destructor.

---

Member Function Documentation

int TAO_Notify_Method_Request_Dispatch_Queueable::execute ( void  )

virtual

Execute the Request.

Implements TAO_Notify_Method_Request.

---

Member Data Documentation

TAO_Notify_Event::Ptr TAO_Notify_Method_Request_Dispatch_Queueable::event_var_

private

TAO_Notify_ProxySupplier::Ptr TAO_Notify_Method_Request_Dispatch_Queueable::proxy_guard_

private

---

The documentation for this class was generated from the following files:

• Method_Request_Dispatch.h
• Method_Request_Dispatch.cpp