24 #ifndef OMNIEVENTS__EVENTCHANNEL_H
25 #define OMNIEVENTS__EVENTCHANNEL_H
34 # include <iostream.h>
39 #include "omniEvents.hh"
46 #ifdef HAVE_STD_IOSTREAM
52 class SupplierAdmin_i;
53 class ConsumerAdmin_i;
54 class EventChannelStore;
112 :
public POA_omniEvents::EventChannel,
117 CosEventChannelAdmin::ConsumerAdmin_ptr for_consumers();
118 CosEventChannelAdmin::SupplierAdmin_ptr for_suppliers();
132 void activate(
const char* channelName,
const PersistNode* node =NULL);
135 void start(){
DB(0,
"It is no longer necessary to call EventChannel::start().")}
141 void* run_undetached(
void*);
164 void output(ostream& os);
169 {assert(_consumerAdmin!=NULL);
return *_consumerAdmin;}
171 {
return _properties;}
187 void setInsName(
const string v);
193 void createPoa(
const char* channelName);
216 void output(ostream &os);
#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.
void start()
Warn about interface change.
ConsumerAdmin_i & consumerAdmin() const
EventChannelStore * _eventChannelStore
CORBA::ULong maxQueueLength() const
ConsumerAdmin_i * _consumerAdmin
const PersistNode & properties() const
CORBA::ULong pullRetryPeriod_ms() const
PortableServer::POAManager_var _poaManager
CORBA::Boolean is_alive()
'ping' method inherited from FT::PullMonitorable.
CORBA::ULong maxNumProxies() const
unsigned long cyclePeriod_ns() const
SupplierAdmin_i * _supplierAdmin
Container for Event Channels.
set< EventChannel_i * > _channels
A dummy servant that installs itself into the INSPOA and redirects all calls to the real destination.