24 #ifndef OMNIEVENTS__CONSUMERADMIN_H
25 #define OMNIEVENTS__CONSUMERADMIN_H
36 # include <iostream.h>
41 #include "CosEventChannelAdmin.hh"
43 #ifdef HAVE_STD_IOSTREAM
50 class ProxyPushSupplierManager;
51 class ProxyPullSupplierManager;
55 :
public virtual POA_CosEventChannelAdmin::ConsumerAdmin,
56 public PortableServer::RefCountServantBase,
60 CosEventChannelAdmin::ProxyPushSupplier_ptr obtain_push_supplier();
61 CosEventChannelAdmin::ProxyPullSupplier_ptr obtain_pull_supplier();
71 void send(CORBA::Any* event);
76 void send(list<CORBA::Any*>& events);
85 void output(ostream& os);
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
ProxyPushSupplierManager * _pushSupplier
const EventChannel_i & _channel
ProxyPullSupplierManager * _pullSupplier
Servant for CosEventChannelAdmin::EventChannel objects, also inherits from omni_thread.
The EventQueue is a circular buffer, that contains _size-1 events.