diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.h')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.h | 19 |
1 files changed, 12 insertions, 7 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.h b/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.h index 4dee0091898..7fdf340e443 100644 --- a/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.h +++ b/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.h @@ -77,6 +77,18 @@ public: typedef TAO_EC_ProxyPushSupplier_Set::Busy_Lock Busy_Lock; Busy_Lock& busy_lock (void); + void busy_hwm (CORBA::ULong hwm); + CORBA::ULong busy_hwm (void) const; + void max_write_delay (CORBA::ULong hwm); + CORBA::ULong max_write_delay (void) const; + // Delegate on the EC_ProxyPushSupplier.... + + void set_default_POA (PortableServer::POA_ptr poa); + // Set this servant's default POA + + virtual PortableServer::POA_ptr _default_POA (CORBA::Environment& env); + // Override the ServantBase method. + virtual void connected (TAO_EC_ProxyPushConsumer*, CORBA::Environment&); virtual void disconnected (TAO_EC_ProxyPushConsumer*, @@ -91,17 +103,10 @@ public: // Used to inform the EC that a Supplier has connected or // disconnected from it. - virtual void shutdown (CORBA::Environment&); - // The event channel is shutting down, inform all the consumers of - // this - // = The RtecEventChannelAdmin::ConsumerAdmin methods... virtual RtecEventChannelAdmin::ProxyPushSupplier_ptr obtain_push_supplier (CORBA::Environment &); - // = The PortableServer::ServantBase methods - virtual PortableServer::POA_ptr _default_POA (CORBA::Environment& env); - private: TAO_EC_Event_Channel *event_channel_; // The Event Channel we belong to |