OmniEvents
OmniEvents::ProxyManager Class Reference

Base class for ServantActivator classes that manage Proxy servants. More...

#include <ProxyManager.h>

Inheritance diagram for OmniEvents::ProxyManager:
Collaboration diagram for OmniEvents::ProxyManager:

Public Member Functions

void etherealize (const PortableServer::ObjectId &oid, PortableServer::POA_ptr adapter, PortableServer::Servant serv, CORBA::Boolean cleanup_in_progress, CORBA::Boolean remaining_activations)
 Implements etherealize() method from ServantActivator interface.
 
void reincarnate (const PersistNode &node)
 Re-create servants from information saved in the log file.
 
void output (ostream &os)
 Save this object's state to a stream.
 
- Public Member Functions inherited from OmniEvents::Servant
virtual PortableServer::POA_ptr _default_POA ()
 
virtual ~Servant ()
 

Protected Member Functions

 ProxyManager (PortableServer::POA_ptr poa)
 
virtual ~ProxyManager ()
 
void activate (const char *name)
 Creates the Proxy-type's POA, and registers this object as its ServantManager.
 
- Protected Member Functions inherited from OmniEvents::Servant
 Servant (PortableServer::POA_ptr poa)
 
void activateObjectWithId (const char *oidStr)
 Calls activate_object_with_id() to activate this servant in its POA.
 
void deactivateObject ()
 Calls deactivate_object() to deactivate this servant in its POA.
 

Protected Attributes

set< Proxy * > _servants
 The set of all active Proxies in this object's _managedPoa.
 
PortableServer::POA_var _managedPoa
 The POA owned & managed by this object.
 
- Protected Attributes inherited from OmniEvents::Servant
PortableServer::POA_var _poa
 

Detailed Description

Base class for ServantActivator classes that manage Proxy servants.

Each ProxyManager manages its own POA (_managedPoa), with policies: PERSISTENT, USER_ID, NO_IMPLICIT_ACTIVATION, USE_SERVANT_MANAGER, SINGLE_THREAD_MODEL. This POA is only used to contain objects of a single Proxy type. Specific subclasses must implement incarnate() & createObject() methods.

Definition at line 57 of file ProxyManager.h.

Constructor & Destructor Documentation

◆ ProxyManager()

OmniEvents::ProxyManager::ProxyManager ( PortableServer::POA_ptr  poa)
protected
Parameters
poaparent POA.

Definition at line 96 of file ProxyManager.cc.

◆ ~ProxyManager()

OmniEvents::ProxyManager::~ProxyManager ( )
protectedvirtual

Definition at line 152 of file ProxyManager.cc.

Member Function Documentation

◆ activate()

void OmniEvents::ProxyManager::activate ( const char name)
protected

Creates the Proxy-type's POA, and registers this object as its ServantManager.

Parameters
namee.g. "ProxyPushSupplier".

Definition at line 103 of file ProxyManager.cc.

References _managedPoa, OmniEvents::Servant::_poa, OmniEvents::Servant::activateObjectWithId(), and DB.

Referenced by OmniEvents::ProxyPullConsumerManager::ProxyPullConsumerManager(), OmniEvents::ProxyPullSupplierManager::ProxyPullSupplierManager(), and OmniEvents::ProxyPushSupplierManager::ProxyPushSupplierManager().

◆ etherealize()

void OmniEvents::ProxyManager::etherealize ( const PortableServer::ObjectId &  oid,
PortableServer::POA_ptr  adapter,
PortableServer::Servant  serv,
CORBA::Boolean  cleanup_in_progress,
CORBA::Boolean  remaining_activations 
)

Implements etherealize() method from ServantActivator interface.

Definition at line 41 of file ProxyManager.cc.

References _servants, and DB.

◆ output()

void OmniEvents::ProxyManager::output ( ostream os)

Save this object's state to a stream.

Definition at line 87 of file ProxyManager.cc.

References _servants, and OmniEvents::Proxy::output().

Referenced by OmniEvents::ConsumerAdmin_i::output(), and OmniEvents::SupplierAdmin_i::output().

◆ reincarnate()

void OmniEvents::ProxyManager::reincarnate ( const PersistNode node)

Re-create servants from information saved in the log file.

Definition at line 60 of file ProxyManager.cc.

References OmniEvents::PersistNode::_child, _managedPoa, _servants, DB, and OmniEvents::Proxy::reincarnate().

Referenced by OmniEvents::ConsumerAdmin_i::reincarnate(), and OmniEvents::SupplierAdmin_i::reincarnate().

Member Data Documentation

◆ _managedPoa

PortableServer::POA_var OmniEvents::ProxyManager::_managedPoa
protected

◆ _servants


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