24 #ifndef OMNIEVENTS__PROXYPUSHCONSUMER_H
25 #define OMNIEVENTS__PROXYPUSHCONSUMER_H
38 # include <iostream.h>
44 #include "CosEventChannelAdmin.hh"
46 #ifdef HAVE_STD_IOSTREAM
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;
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
Interface for classes that wish to receive callbacks from deferred requests.
Default servant for ProxyPushConsumer objects.
list< CORBA::Any * > & _queue
ConsumerAdmin_i & _consumerAdmin
CORBA::String_var _channelName
Connections_t _connections
bool _useLocalQueue
Switch between RT/chunked modes.
map< string, Connection * > Connections_t
bool _targetIsProxy
TRUE if _target is a ProxyPushSupplier.
Connection()
NO IMPLEMENTATION.
const char * _channelName
CosEventComm::PushSupplier_var _target