#include <CEC_Reactive_ConsumerControl.h>
Inheritance diagram for TAO_CEC_Ping_Push_Consumer:
Public Member Functions | |
TAO_CEC_Ping_Push_Consumer (TAO_CEC_ConsumerControl *control) | |
virtual void | work (TAO_CEC_ProxyPushSupplier *supplier) |
Private Attributes | |
TAO_CEC_ConsumerControl * | control_ |
Definition at line 174 of file CEC_Reactive_ConsumerControl.h.
TAO_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE TAO_CEC_Ping_Push_Consumer::TAO_CEC_Ping_Push_Consumer | ( | TAO_CEC_ConsumerControl * | control | ) |
Definition at line 9 of file CEC_Reactive_ConsumerControl.inl.
00010 : control_ (control) 00011 { 00012 }
void TAO_CEC_Ping_Push_Consumer::work | ( | TAO_CEC_ProxyPushSupplier * | supplier | ) | [virtual] |
Implements TAO_ESF_Worker< TAO_CEC_ProxyPushSupplier >.
Definition at line 384 of file CEC_Reactive_ConsumerControl.cpp.
References TAO_CEC_ProxyPushSupplier::consumer_non_existent(), TAO_CEC_ConsumerControl::consumer_not_exist(), and control_.
00385 { 00386 try 00387 { 00388 CORBA::Boolean disconnected; 00389 CORBA::Boolean non_existent = 00390 supplier->consumer_non_existent (disconnected); 00391 if (non_existent && !disconnected) 00392 { 00393 this->control_->consumer_not_exist (supplier); 00394 } 00395 } 00396 catch (const CORBA::OBJECT_NOT_EXIST& ) 00397 { 00398 this->control_->consumer_not_exist (supplier); 00399 } 00400 catch (const CORBA::TRANSIENT& ) 00401 { 00402 if (this->control_->need_to_disconnect (supplier)) 00403 { 00404 this->control_->consumer_not_exist (supplier); 00405 } 00406 } 00407 catch (const CORBA::Exception&) 00408 { 00409 // Ignore all exceptions 00410 } 00411 }