33 namespace OmniEvents {
36 CosEventChannelAdmin::ProxyPushSupplier_ptr
45 CosEventChannelAdmin::ProxyPullSupplier_ptr
56 PortableServer::POA_ptr poa
60 _queue(channel.maxQueueLength()),
82 DB(20,
"~ConsumerAdmin_i()")
102 _queue.append(event);
111 for(list<CORBA::Any*>::iterator i=events.begin(); i!=events.end(); ++i)
131 if(pushsNode && !pushsNode->
_child.empty())
139 if(pullsNode && !pullsNode->
_child.empty())