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);
#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.
list< CORBA::Any * > _queue
Incoming queue for the PushConsumer.
pair< unsigned long, unsigned long > _nextPull
Next time to retry pull (sec,nsec).
const EventChannel_i & _channel
ProxyPushConsumer_i * _pushConsumer
ProxyPullConsumerManager * _pullConsumer