#include <CEC_Reactive_ConsumerControl.h>
Inheritance diagram for TAO_CEC_Ping_Pull_Consumer:
Public Member Functions | |
TAO_CEC_Ping_Pull_Consumer (TAO_CEC_ConsumerControl *control) | |
virtual void | work (TAO_CEC_ProxyPullSupplier *supplier) |
Private Attributes | |
TAO_CEC_ConsumerControl * | control_ |
Definition at line 188 of file CEC_Reactive_ConsumerControl.h.
ACE_INLINE TAO_CEC_Ping_Pull_Consumer::TAO_CEC_Ping_Pull_Consumer | ( | TAO_CEC_ConsumerControl * | control | ) |
Definition at line 18 of file CEC_Reactive_ConsumerControl.inl.
00019 : control_ (control) 00020 { 00021 }
void TAO_CEC_Ping_Pull_Consumer::work | ( | TAO_CEC_ProxyPullSupplier * | supplier | ) | [virtual] |
Implements TAO_ESF_Worker< TAO_CEC_ProxyPullSupplier >.
Definition at line 416 of file CEC_Reactive_ConsumerControl.cpp.
References TAO_CEC_ProxyPullSupplier::consumer_non_existent(), TAO_CEC_ConsumerControl::consumer_not_exist(), and control_.
00417 { 00418 try 00419 { 00420 CORBA::Boolean disconnected; 00421 CORBA::Boolean non_existent = 00422 supplier->consumer_non_existent (disconnected); 00423 if (non_existent && !disconnected) 00424 { 00425 this->control_->consumer_not_exist (supplier); 00426 } 00427 } 00428 catch (const CORBA::OBJECT_NOT_EXIST& ) 00429 { 00430 this->control_->consumer_not_exist (supplier); 00431 } 00432 catch (const CORBA::TRANSIENT& ) 00433 { 00434 if (this->control_->need_to_disconnect (supplier)) 00435 { 00436 this->control_->consumer_not_exist (supplier); 00437 } 00438 } 00439 catch (const CORBA::Exception&) 00440 { 00441 // Ignore all exceptions 00442 } 00443 }