24 #ifndef OMNIEVENTS__SUPPLIERADMIN_H 25 #define OMNIEVENTS__SUPPLIERADMIN_H 36 # include <iostream.h> 40 #include "CosEventChannelAdmin.hh" 42 #ifdef HAVE_STD_IOSTREAM 49 class ProxyPushConsumer_i;
50 class ProxyPullConsumerManager;
54 :
public virtual POA_CosEventChannelAdmin::SupplierAdmin,
55 public PortableServer::RefCountServantBase,
59 CosEventChannelAdmin::ProxyPushConsumer_ptr obtain_push_consumer();
60 CosEventChannelAdmin::ProxyPullConsumer_ptr obtain_pull_consumer();
68 void collect(list<CORBA::Any*>& events);
77 void output(ostream& os);
92 #endif // OMNIEVENTS__SUPPLIERADMIN_H ProxyPullConsumerManager * _pullConsumer
pair< unsigned long, unsigned long > _nextPull
Next time to retry pull (sec,nsec).
ProxyPushConsumer_i * _pushConsumer
list< CORBA::Any * > _queue
Incoming queue for the PushConsumer.
const EventChannel_i & _channel
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
Servant for CosEventChannelAdmin::EventChannel objects, also inherits from omni_thread.
Default servant for ProxyPushConsumer objects.