24#ifndef OMNIEVENTS__SUPPLIERADMIN_H
25#define OMNIEVENTS__SUPPLIERADMIN_H
40#include "CosEventChannelAdmin.hh"
42#ifdef HAVE_STD_IOSTREAM
49class ProxyPushConsumer_i;
50class ProxyPullConsumerManager;
54:
public virtual POA_CosEventChannelAdmin::SupplierAdmin,
55 public PortableServer::RefCountServantBase,
68 void collect(list<CORBA::Any*>& events);
#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).
CosEventChannelAdmin::ProxyPushConsumer_ptr obtain_push_consumer()
SupplierAdmin_i(const EventChannel_i &channel, PortableServer::POA_ptr poa)
const EventChannel_i & _channel
void disconnect()
Send disconnect_XXX_supplier() to all connected consumers.
void output(ostream &os)
Save this object's state to a stream.
virtual ~SupplierAdmin_i()
ProxyPushConsumer_i * _pushConsumer
ProxyPullConsumerManager * _pullConsumer
OMNIEVENTS__DEBUG_REF_COUNTS__DECL void collect(list< CORBA::Any * > &events)
Collects all events that have arrived since the last call.
void reincarnate(const PersistNode &node)
Populate this servant from log information.
CosEventChannelAdmin::ProxyPullConsumer_ptr obtain_pull_consumer()