24 #ifndef OMNIEVENTS__PROXYPULLCONSUMER_H
25 #define OMNIEVENTS__PROXYPULLCONSUMER_H
36 # include <iostream.h>
41 #include "CosEventChannelAdmin.hh"
43 #ifdef HAVE_STD_IOSTREAM
51 public PortableServer::RefCountServantBase
54 PortableServer::Servant incarnate(
55 const PortableServer::ObjectId& oid,
56 PortableServer::POA_ptr poa
60 PortableServer::POA_ptr parentPoa,
65 CosEventChannelAdmin::ProxyPullConsumer_ptr createObject();
83 void triggerRequest();
101 :
public virtual POA_CosEventChannelAdmin::ProxyPullConsumer,
105 void connect_pull_supplier(CosEventComm::PullSupplier_ptr pullSupplier);
106 void disconnect_pull_consumer();
114 void triggerRequest();
116 void reincarnate(
const string& oid,
const PersistNode& node);
117 void output(ostream& os);
123 enum Mode { Pull=0, TryPull=1 };
#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.
list< CORBA::Any * > & _queue
Implementation of the ProxyPullConsumer interface.
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...
list< CORBA::Any * > & _queue