24#ifndef OMNIEVENTS__EVENTCHANNEL_H
25#define OMNIEVENTS__EVENTCHANNEL_H
39#include "omniEvents.hh"
46#ifdef HAVE_STD_IOSTREAM
54class EventChannelStore;
112:
public POA_omniEvents::EventChannel,
135 void start(){
DB(0,
"It is no longer necessary to call EventChannel::start().")}
#define PULL_RETRY_PERIOD_MS
1 second
#define CYCLE_PERIOD_NS
Delay between cycles. (0.1 second)
#define MAX_NUM_PROXIES
Only limits number of ProxyPullSuppliers.
Servant for CosEventChannelAdmin::EventChannel objects, also inherits from omni_thread.
const PersistNode & properties() const
void activate(const char *channelName, const PersistNode *node=NULL)
Creates the channel's POA, and any child objects.
~EventChannel_i()
Cleans up the _poa, if this object is deleted before its thread starts.
void _remove_ref()
Shutdown the thread when refCount reaches zero.
void start()
Warn about interface change.
void mainLoop()
The main loop for a channel.
void * run_undetached(void *)
Entry point for the channel's thread.
EventChannelStore * _eventChannelStore
CORBA::ULong maxQueueLength() const
ConsumerAdmin_i & consumerAdmin() const
ConsumerAdmin_i * _consumerAdmin
CORBA::ULong pullRetryPeriod_ms() const
PortableServer::POAManager_var _poaManager
CORBA::Boolean is_alive()
'ping' method inherited from FT::PullMonitorable.
CORBA::ULong maxNumProxies() const
void createPoa(const char *channelName)
Constructs the main POA for this channel.
unsigned long cyclePeriod_ns() const
CosEventChannelAdmin::ConsumerAdmin_ptr for_consumers()
CosEventChannelAdmin::SupplierAdmin_ptr for_suppliers()
SupplierAdmin_i * _supplierAdmin
void setInsName(const string v)
Construct a new Mapper object, and registers it in the INSPOA.
Container for Event Channels.
void insert(EventChannel_i *channel)
set< EventChannel_i * > _channels
void erase(EventChannel_i *channel)
A dummy servant that installs itself into the INSPOA and redirects all calls to the real destination.
long attrLong(const string &key, long fallback=0) const