24#ifndef OMNIEVENTS__CONSUMERADMIN_H
25#define OMNIEVENTS__CONSUMERADMIN_H
41#include "CosEventChannelAdmin.hh"
43#ifdef HAVE_STD_IOSTREAM
50class ProxyPushSupplierManager;
51class ProxyPullSupplierManager;
55:
public virtual POA_CosEventChannelAdmin::ConsumerAdmin,
56 public PortableServer::RefCountServantBase,
71 void send(CORBA::Any* event);
76 void send(list<CORBA::Any*>& events);
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
OMNIEVENTS__DEBUG_REF_COUNTS__DECL void send(CORBA::Any *event)
Queues a single event for sending to consumers.
virtual ~ConsumerAdmin_i()
void reincarnate(const PersistNode &node)
Populate this servant from log information.
void disconnect()
Send disconnect_XXX_consumer() to all connected consumers.
ProxyPushSupplierManager * _pushSupplier
const EventChannel_i & _channel
CosEventChannelAdmin::ProxyPushSupplier_ptr obtain_push_supplier()
CosEventChannelAdmin::ProxyPullSupplier_ptr obtain_pull_supplier()
void output(ostream &os)
Save this object's state to a stream.
ProxyPullSupplierManager * _pullSupplier
Servant for CosEventChannelAdmin::EventChannel objects, also inherits from omni_thread.
The EventQueue is a circular buffer, that contains _size-1 events.