24 #ifndef OMNIEVENTS__PROXYPULLSUPPLIER_H
25 #define OMNIEVENTS__PROXYPULLSUPPLIER_H
34 # include <iostream.h>
40 #include "CosEventChannelAdmin.hh"
42 #ifdef HAVE_STD_IOSTREAM
46 namespace OmniEvents {
52 public PortableServer::RefCountServantBase
55 PortableServer::Servant incarnate(
56 const PortableServer::ObjectId& oid,
57 PortableServer::POA_ptr poa
62 PortableServer::POA_ptr parentPoa,
67 CosEventChannelAdmin::ProxyPullSupplier_ptr createObject();
85 :
public virtual POA_CosEventChannelAdmin::ProxyPullSupplier,
90 void connect_pull_consumer(CosEventComm::PullConsumer_ptr pullConsumer);
91 void disconnect_pull_supplier();
93 CORBA::Any* try_pull(CORBA::Boolean& has_event);
97 void reincarnate(
const string& oid,
const PersistNode& node);
98 void output(ostream& os);
99 inline unsigned long timestamp()
const {
return _timestamp;}
115 #endif // OMNIEVENTS__PROXYPULLSUPPLIER_H