24 #ifndef OMNIEVENTS__PROXYPUSHCONSUMER_H
25 #define OMNIEVENTS__PROXYPUSHCONSUMER_H
38 # include <iostream.h>
44 #include "CosEventChannelAdmin.hh"
46 #ifdef HAVE_STD_IOSTREAM
50 namespace OmniEvents {
53 class ConsumerAdmin_i;
61 :
public virtual POA_CosEventChannelAdmin::ProxyPushConsumer,
68 void connect_push_supplier(CosEventComm::PushSupplier_ptr pushSupplier);
73 void disconnect_push_consumer();
76 void push(
const CORBA::Any& event);
80 PortableServer::POA_ptr parentPoa,
94 CosEventChannelAdmin::ProxyPushConsumer_ptr createObject();
102 void output(ostream& os)
const;
105 string currentObjectId()
const;
115 const char* channelName,
116 const string& oidstr,
117 CosEventComm::PushSupplier_ptr pushSupplier,
123 void callback(CORBA::Request_ptr req);
125 void output(ostream& os)
const;
128 #if OMNIEVENTS__DEBUG_SERVANT
129 static int _objectCount;
143 #endif // OMNIEVENTS__PROXYPUSHCONSUMER_H