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,
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
T::_ptr_type createNarrowedReference(PortableServer::POA_ptr poa, const char *repositoryId)
Helper method that creates a new CORBA object and then narrows it to the appropriate type.
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()
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()