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())
#define OMNIEVENTS__DEBUG_REF_COUNTS__DEFN(C)
Defines debug versions of _add/remove_ref() for class C.
OMNIEVENTS__DEBUG_REF_COUNTS__DECL void send(CORBA::Any *event)
Queues a single event for sending to consumers.
virtual ~ConsumerAdmin_i()
ConsumerAdmin_i(const EventChannel_i &channel, PortableServer::POA_ptr poa)
void reincarnate(const PersistNode &node)
Populate this servant from log information.
void disconnect()
Send disconnect_XXX_consumer() to all connected consumers.
ProxyPushSupplierManager * _pushSupplier
const EventChannel_i & _channel
CosEventChannelAdmin::ProxyPushSupplier_ptr obtain_push_supplier()
CosEventChannelAdmin::ProxyPullSupplier_ptr obtain_pull_supplier()
void output(ostream &os)
Save this object's state to a stream.
ProxyPullSupplierManager * _pullSupplier
Servant for CosEventChannelAdmin::EventChannel objects, also inherits from omni_thread.
const PersistNode & properties() const
void setFilter(Filter *filter)
void append(CORBA::Any *event)
The most basic event filter allows only events of a certain CORBA TCKind to pass.
Allows only events of a certain CORBA RepositoryId to pass.
map< string, PersistNode * > _child
bool hasAttr(const string &key) const
string attrString(const string &key, const string &fallback="") const
long attrLong(const string &key, long fallback=0) const
PersistNode * child(const string &key) const
void reincarnate(const PersistNode &node)
Re-create servants from information saved in the log file.
void output(ostream &os)
Save this object's state to a stream.
void disconnect()
Send disconnect_pull_consumer() to all connected PullConsumers.
OMNIEVENTS__DEBUG_REF_COUNTS__DECL CosEventChannelAdmin::ProxyPullSupplier_ptr createObject()
void disconnect()
Send disconnect_push_consumer() to all connected PushConsumers.
CosEventChannelAdmin::ProxyPushSupplier_ptr createObject()
void _remove_ref()
Shutdown the thread when refCount reaches zero.
Helper class that locks ProxyPushSupplier upon construction, and wakes it up on destruction.
PortableServer::POA_var _poa
void activateObjectWithId(const char *oidStr)
Calls activate_object_with_id() to activate this servant in its POA.