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
65 CosEventChannelAdmin::ProxyPullConsumer_ptr
createObject();
101:
public virtual POA_CosEventChannelAdmin::ProxyPullConsumer,
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
T::_ptr_type createNarrowedReference(PortableServer::POA_ptr poa, const char *repositoryId)
Helper method that creates a new CORBA object and then narrows it to the appropriate type.
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()
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)
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.