24 #ifndef OMNIEVENTS__EVENTCHANNEL_H
25 #define OMNIEVENTS__EVENTCHANNEL_H
34 # include <iostream.h>
39 #include "omniEvents.hh"
46 #ifdef HAVE_STD_IOSTREAM
50 namespace OmniEvents {
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;}
175 CORBA::ULong pullRetryPeriod_ms()
const
177 CORBA::ULong maxQueueLength()
const
179 CORBA::ULong maxNumProxies()
const
181 unsigned long cyclePeriod_ns()
const
187 void setInsName(
const string v);
193 void createPoa(
const char* channelName);
216 void output(ostream &os);
224 #endif // OMNIEVENTS__EVENTCHANNEL_H