OmniEvents
OmniEvents::ProxyPullSupplierManager Class Reference

#include <ProxyPullSupplier.h>

Inheritance diagram for OmniEvents::ProxyPullSupplierManager:
Collaboration diagram for OmniEvents::ProxyPullSupplierManager:

Public Member Functions

PortableServer::Servant incarnate (const PortableServer::ObjectId &oid, PortableServer::POA_ptr poa)
 
 ProxyPullSupplierManager (const EventChannel_i &channel, PortableServer::POA_ptr parentPoa, EventQueue &q)
 
 ~ProxyPullSupplierManager ()
 
OMNIEVENTS__DEBUG_REF_COUNTS__DECL CosEventChannelAdmin::ProxyPullSupplier_ptr createObject ()
 
void disconnect ()
 Send disconnect_pull_consumer() to all connected PullConsumers.
 
- Public Member Functions inherited from OmniEvents::ProxyManager
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 ()
 

Private Attributes

const EventChannel_i_channel
 
EventQueue_queue
 Reference to queue shared with ProxyPushSuppliers.
 
int _maxNumProxies
 Upper limit on number of proxies.
 

Additional Inherited Members

- Protected Member Functions inherited from OmniEvents::ProxyManager
 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 inherited from OmniEvents::ProxyManager
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

Definition at line 50 of file ProxyPullSupplier.h.

Constructor & Destructor Documentation

◆ ProxyPullSupplierManager()

OmniEvents::ProxyPullSupplierManager::ProxyPullSupplierManager ( const EventChannel_i channel,
PortableServer::POA_ptr  parentPoa,
EventQueue q 
)

Definition at line 62 of file ProxyPullSupplier.cc.

References OmniEvents::ProxyManager::activate().

◆ ~ProxyPullSupplierManager()

OmniEvents::ProxyPullSupplierManager::~ProxyPullSupplierManager ( )

Definition at line 74 of file ProxyPullSupplier.cc.

References DB.

Member Function Documentation

◆ createObject()

CosEventChannelAdmin::ProxyPullSupplier_ptr OmniEvents::ProxyPullSupplierManager::createObject ( )

◆ disconnect()

void OmniEvents::ProxyPullSupplierManager::disconnect ( )

Send disconnect_pull_consumer() to all connected PullConsumers.

Definition at line 90 of file ProxyPullSupplier.cc.

References OmniEvents::ProxyManager::_servants, OmniEvents::createNarrowedReference(), and OmniEvents::ProxyPullSupplier_i::disconnect_pull_supplier().

Referenced by OmniEvents::ConsumerAdmin_i::disconnect().

◆ incarnate()

PortableServer::Servant OmniEvents::ProxyPullSupplierManager::incarnate ( const PortableServer::ObjectId &  oid,
PortableServer::POA_ptr  poa 
)

Member Data Documentation

◆ _channel

const EventChannel_i& OmniEvents::ProxyPullSupplierManager::_channel
private

Definition at line 73 of file ProxyPullSupplier.h.

Referenced by incarnate().

◆ _maxNumProxies

int OmniEvents::ProxyPullSupplierManager::_maxNumProxies
private

Upper limit on number of proxies.

Definition at line 75 of file ProxyPullSupplier.h.

◆ _queue

EventQueue& OmniEvents::ProxyPullSupplierManager::_queue
private

Reference to queue shared with ProxyPushSuppliers.

Definition at line 74 of file ProxyPullSupplier.h.

Referenced by incarnate().


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