TAO_Notify Namespace Reference

A namespace to be used by all of TAO's Notification Service implementation. More...

Classes
class	Bit_Vector
	Simple bit vector. More...
class	Delivery_Request
	Represents a request to deliver an event to a particular destination. More...
class	Event_Persistence_Factory
	interface to be implemented by specific Event_Persistence_Factories More...
class	Event_Persistence_Strategy
	Interface to be implemented by specific strategies. More...
class	NVP
	Name/Value Pair. More...
class	NVPList
	Collection of Name/Value Pairs. More...
class	Persistent_Callback
	An interface to allow callbacks on completion of persistent storage requests. More...
class	Persistent_Storage_Block
	A class to represent a block on disk. More...
class	Persistent_File_Allocator
	A class that manages the details of persistent storage. More...
class	Random_File
	A random file class. More...
class	Reconnect_Worker
	Iterate through children reconnecting after reloading persistent information. More...
class	Reconnection_Registry
	Implementation of ReconnectionRegistry. More...
class	Routing_Slip
	Class which manages the delivery of events to destination. More...
class	Routing_Slip_Persistence_Manager
	Manage interaction between Routing_Slip and persistent storage. More...
class	Routing_Slip_Persistence_Manager::Block_Header
	private: Storage for header information of all persistent block. More...
class	Routing_Slip_Persistence_Manager::Routing_Slip_Header
	private: Storage for header information for Routing_Slip blocks. More...
class	Routing_Slip_Persistence_Manager::Event_Header
	An Event block header. More...
class	Routing_Slip_Persistence_Manager::Overflow_Header
	An overflow block header. More...
class	Routing_Slip_Queue
	A queue of Routing_Slips waiting to be persisted. More...
class	Save_Persist_Worker
	Iterate through children saving persistent topology information. More...
class	Standard_Event_Persistence_Factory
	Standard (i.e. default) implementation of Event_Persistence_Factory interface. More...
class	Standard_Event_Persistence
	The standard implementation of the Event_Persistence_Strategy interface. More...
class	Topology_Factory
	Service Object to allow dynamic control of the loaded saver factory. More...
class	Topology_Loader
	An interface for an object that loads Persistent Topology Information. More...
class	Topology_Savable
	Interface to be implemented by savable topology objects. More...
class	Topology_Object
	Base class for Persistent Topology Objects. More...
class	Topology_Parent
	Interface for topology objects that act as parents. More...
class	Topology_Saver
	An interface to be implemented by objects that save Topology. More...
class	XML_Loader
	Load Notification Service Topology from an XML file. More...
class	XML_Saver
	Save Notification Service Topology to an XML file. More...
class	XML_Topology_Factory
	Create XML topology savers and loaders. More...
Typedefs
typedef ACE_Strong_Bound_Ptr< Delivery_Request, TAO_SYNCH_MUTEX >	Delivery_Request_Ptr
	A reference-counted smart pointer to a Delivery_Request.
typedef ACE_Unbounded_Queue< Delivery_Request_Ptr >	Delivery_Request_Queue
typedef ACE_Strong_Bound_Ptr< Routing_Slip, TAO_SYNCH_MUTEX >	Routing_Slip_Ptr
	A reference-counted smart pointer to a Routing_Slip.
typedef ACE_Vector< Delivery_Request_Ptr >	Delivery_Request_Vec
	A vector of Delivery Requests. The body of a Routing_Slip.
typedef ACE_Vector< TAO_Notify_Method_Request_Queueable * >	Delivery_Method_Vec
	A vector of Methods_. Used during recovery.
typedef ACE_Vector< TAO_Notify_Object::ID >	IdVec
	A vector of IDS. Used as a path from the EventChannelFactory to a proxy.
Variables
const char	REGISTRY_TYPE [] = "reconnect_registry"
const char	RECONNECT_ID [] = "ReconnectId"
const char	RECONNECT_IOR [] = "IOR"
const char	REGISTRY_CALLBACK_TYPE [] = "reconnect_callback"
const ACE_UINT32	ROUTING_SLIP_ROOT_BLOCK_NUMBER = 0
const ACE_UINT64	ROUTING_SLIP_ROOT_SERIAL_NUMBER = 1
const char	TOPOLOGY_ID_NAME [] = "TopologyID"

---

Detailed Description

A namespace to be used by all of TAO's Notification Service implementation.

The initial implementation used the TAO_Notify_ prefix rather than a namespace. As part of the reliable Notification Service project we started using this TAO_Notify namespace, but there are still many parts of the Notification Service that are in the global namespace with a TAO_NS prefix.

---

Typedef Documentation

typedef ACE_Vector<TAO_Notify_Method_Request_Queueable *> TAO_Notify::Delivery_Method_Vec

A vector of Methods_. Used during recovery. Definition at line 51 of file Routing_Slip.h.

typedef ACE_Strong_Bound_Ptr<Delivery_Request, TAO_SYNCH_MUTEX> TAO_Notify::Delivery_Request_Ptr

A reference-counted smart pointer to a Delivery_Request. Definition at line 30 of file Delivery_Request.h. Referenced by TAO_Notify::Routing_Slip::dispatch(), TAO_Notify::Routing_Slip::route(), TAO_Notify_Method_Request_Dispatch::TAO_Notify_Method_Request_Dispatch(), TAO_Notify_Method_Request_Dispatch_Queueable::TAO_Notify_Method_Request_Dispatch_Queueable(), TAO_Notify_Method_Request_Event::TAO_Notify_Method_Request_Event(), TAO_Notify_Method_Request_Event_Queueable::TAO_Notify_Method_Request_Event_Queueable(), TAO_Notify_Method_Request_Lookup_Queueable::TAO_Notify_Method_Request_Lookup_Queueable(), TAO_Notify::Routing_Slip::unmarshal(), TAO_Notify_Method_Request_Lookup::unmarshal(), and TAO_Notify_Method_Request_Dispatch::unmarshal().

typedef ACE_Unbounded_Queue<Delivery_Request_Ptr> TAO_Notify::Delivery_Request_Queue

Definition at line 32 of file Delivery_Request.h.

typedef ACE_Vector<Delivery_Request_Ptr> TAO_Notify::Delivery_Request_Vec

A vector of Delivery Requests. The body of a Routing_Slip. Definition at line 48 of file Routing_Slip.h.

typedef ACE_Vector<TAO_Notify_Object::ID> TAO_Notify::IdVec

A vector of IDS. Used as a path from the EventChannelFactory to a proxy. Definition at line 53 of file Topology_Object.h. Referenced by TAO_Notify_SupplierAdmin::find_proxy_consumer(), TAO_Notify_EventChannelFactory::find_proxy_consumer(), TAO_Notify_EventChannel::find_proxy_consumer(), TAO_Notify_EventChannelFactory::find_proxy_supplier(), TAO_Notify_EventChannel::find_proxy_supplier(), TAO_Notify_ConsumerAdmin::find_proxy_supplier(), TAO_Notify::Topology_Object::get_id_path(), TAO_Notify::Delivery_Request::set_destination_id(), TAO_Notify_Method_Request_Lookup::unmarshal(), and TAO_Notify_Method_Request_Dispatch::unmarshal().

typedef ACE_Strong_Bound_Ptr< Routing_Slip, TAO_SYNCH_MUTEX > TAO_Notify::Routing_Slip_Ptr

A reference-counted smart pointer to a Routing_Slip. Definition at line 38 of file Delivery_Request.h. Referenced by TAO_Notify::Routing_Slip_Queue::add(), TAO_Notify::Routing_Slip::create(), TAO_Notify::Delivery_Request::Delivery_Request(), TAO_Notify::Routing_Slip_Queue::dispatch_one(), TAO_Notify_EventChannelFactory::load_event_persistence(), TAO_Notify::Routing_Slip::persist_complete(), TAO_Notify_ProxyConsumer::push_i(), and TAO_Notify_EventChannelFactory::reconnect().

---

Variable Documentation

const char TAO_Notify::RECONNECT_ID = "ReconnectId"

Definition at line 27 of file Reconnection_Registry.cpp. Referenced by TAO_Notify::Reconnection_Registry::load_child(), and TAO_Notify::Reconnection_Registry::save_persistent().

const char TAO_Notify::RECONNECT_IOR = "IOR"

Definition at line 28 of file Reconnection_Registry.cpp. Referenced by TAO_Notify::Reconnection_Registry::load_child(), and TAO_Notify::Reconnection_Registry::save_persistent().

const char TAO_Notify::REGISTRY_CALLBACK_TYPE = "reconnect_callback"

Definition at line 29 of file Reconnection_Registry.cpp. Referenced by TAO_Notify::Reconnection_Registry::load_child(), and TAO_Notify::Reconnection_Registry::save_persistent().

const char TAO_Notify::REGISTRY_TYPE = "reconnect_registry"

Definition at line 26 of file Reconnection_Registry.cpp. Referenced by TAO_Notify::Reconnection_Registry::save_persistent().

const ACE_UINT32 TAO_Notify::ROUTING_SLIP_ROOT_BLOCK_NUMBER = 0 [static]

Definition at line 35 of file Standard_Event_Persistence.h.

const ACE_UINT64 TAO_Notify::ROUTING_SLIP_ROOT_SERIAL_NUMBER = 1 [static]

Definition at line 36 of file Standard_Event_Persistence.h.

const char TAO_Notify::TOPOLOGY_ID_NAME = "TopologyID"

Definition at line 16 of file XML_Topology_Factory.cpp. Referenced by TAO_Notify::XML_Saver::begin_object().

---