24#ifndef OMNIEVENTS__PROXYPULLCONSUMER_H
25#define OMNIEVENTS__PROXYPULLCONSUMER_H
41#include "CosEventChannelAdmin.hh"
43#ifdef HAVE_STD_IOSTREAM
51 public PortableServer::RefCountServantBase
55 const PortableServer::ObjectId& oid,
56 PortableServer::POA_ptr poa
60 PortableServer::POA_ptr parentPoa,
65 CosEventChannelAdmin::ProxyPullConsumer_ptr
createObject();
101:
public virtual POA_CosEventChannelAdmin::ProxyPullConsumer,
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
Base class for ServantActivator classes that manage Proxy servants.
Base class for three of the four Proxy servants.
void disconnect()
Send disconnect_pull_supplier() to all connected PullSuppliers.
void triggerRequest()
For each connected proxy, if there is no request in progress, send a new request to the current opera...
void collect()
Collects events that have arrived at connected proxies.
PortableServer::Servant incarnate(const PortableServer::ObjectId &oid, PortableServer::POA_ptr poa)
list< CORBA::Any * > & _queue
OMNIEVENTS__DEBUG_REF_COUNTS__DECL CosEventChannelAdmin::ProxyPullConsumer_ptr createObject()
~ProxyPullConsumerManager()
ProxyPullConsumerManager(PortableServer::POA_ptr parentPoa, list< CORBA::Any * > &q)
Implementation of the ProxyPullConsumer interface.
void output(ostream &os)
Save this object's state to a stream.
void disconnect_pull_consumer()
Mode
This proxy can call out in either pull() or try_pull() mode.
CosEventComm::PullSupplier_var _target
int _exceptionCount
Only when two consecutive exceptions have been received from each mode, do we consider the connection...
void connect_pull_supplier(CosEventComm::PullSupplier_ptr pullSupplier)
ProxyPullConsumer_i(PortableServer::POA_ptr poa, list< CORBA::Any * > &q)
void reincarnate(const string &oid, const PersistNode &node)
Re-create a servant from information saved in the log file.
void triggerRequest()
When _req is NIL, sends out a new pull() or try_pull() call.
list< CORBA::Any * > & _queue
void collect()
Collects responses since the last trigger.