#include <ProxyPushSupplier.h>
Inheritance diagram for TAO_Notify_ProxyPushSupplier:
Public Member Functions | |
TAO_Notify_ProxyPushSupplier (void) | |
Constructor. | |
virtual | ~TAO_Notify_ProxyPushSupplier () |
Destructor. | |
virtual const char * | get_proxy_type_name (void) const |
virtual void | load_attrs (const TAO_Notify::NVPList &attrs) |
virtual CosNotifyChannelAdmin::ProxyType | MyType (void) |
virtual void | connect_any_push_consumer (CosEventComm::PushConsumer_ptr push_consumer) |
virtual void | disconnect_push_supplier () |
Private Types | |
typedef TAO_Notify_ProxySupplier_T< POA_Event_Forwarder::ProxyPushSupplier > | SuperClass |
Private Member Functions | |
virtual void | release (void) |
TAO_Notify_Destroy_Callback methods. | |
Friends | |
class | TAO_Notify_Builder |
Definition at line 46 of file ProxyPushSupplier.h.
typedef TAO_Notify_ProxySupplier_T<POA_Event_Forwarder::ProxyPushSupplier> TAO_Notify_ProxyPushSupplier::SuperClass [private] |
Definition at line 49 of file ProxyPushSupplier.h.
TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Notify_ProxyPushSupplier::TAO_Notify_ProxyPushSupplier | ( | void | ) |
TAO_Notify_ProxyPushSupplier::~TAO_Notify_ProxyPushSupplier | ( | ) | [virtual] |
void TAO_Notify_ProxyPushSupplier::connect_any_push_consumer | ( | CosEventComm::PushConsumer_ptr | push_consumer | ) | [virtual] |
Definition at line 29 of file ProxyPushSupplier.cpp.
References ACE_NEW_THROW_EX, TAO_Notify_ProxySupplier::connect(), TAO_Notify_ProxySupplier::consumer(), and TAO_Notify::Topology_Object::self_change().
Referenced by load_attrs().
00030 { 00031 // Convert Consumer to Base Type 00032 TAO_Notify_PushConsumer* consumer; 00033 ACE_NEW_THROW_EX (consumer, 00034 TAO_Notify_PushConsumer (this), 00035 CORBA::NO_MEMORY ()); 00036 00037 consumer->init (push_consumer); 00038 00039 this->connect (consumer); 00040 this->self_change (); 00041 }
void TAO_Notify_ProxyPushSupplier::disconnect_push_supplier | ( | ) | [virtual] |
Definition at line 44 of file ProxyPushSupplier.cpp.
References TAO_Notify_ProxySupplier::destroy(), and TAO_Notify::Topology_Object::self_change().
00045 { 00046 TAO_Notify_ProxyPushSupplier::Ptr guard( this ); 00047 this->destroy (); 00048 this->self_change (); 00049 }
const char * TAO_Notify_ProxyPushSupplier::get_proxy_type_name | ( | void | ) | const [virtual] |
void TAO_Notify_ProxyPushSupplier::load_attrs | ( | const TAO_Notify::NVPList & | attrs | ) | [virtual] |
Load our attributes. Each derived type should call the superclass load first before loading its own attributes.
Reimplemented from TAO_Notify_Object.
Definition at line 64 of file ProxyPushSupplier.cpp.
References ACE_String_Base< CHAR >::c_str(), connect_any_push_consumer(), TAO_Notify_Properties::instance(), ACE_String_Base< CHAR >::length(), TAO_Notify::NVPList::load(), TAO_Notify_Object::load_attrs(), and TAO_Notify_Properties::orb().
00065 { 00066 SuperClass::load_attrs(attrs); 00067 ACE_CString ior; 00068 if (attrs.load("PeerIOR", ior)) 00069 { 00070 CORBA::ORB_var orb = TAO_Notify_PROPERTIES::instance()->orb(); 00071 try 00072 { 00073 CosNotifyComm::PushConsumer_var pc = 00074 CosNotifyComm::PushConsumer::_nil(); 00075 if (ior.length() > 0) 00076 { 00077 CORBA::Object_var obj = 00078 orb->string_to_object(ior.c_str()); 00079 pc = CosNotifyComm::PushConsumer::_unchecked_narrow(obj.in()); 00080 } 00081 this->connect_any_push_consumer(pc.in()); 00082 } 00083 catch (const CORBA::Exception&) 00084 { 00085 // if we can't reconnect, tough... 00086 } 00087 } 00088 }
CosNotifyChannelAdmin::ProxyType TAO_Notify_ProxyPushSupplier::MyType | ( | void | ) | [virtual] |
Definition at line 52 of file ProxyPushSupplier.cpp.
References CosNotifyChannelAdmin::PUSH_ANY.
00053 { 00054 return CosNotifyChannelAdmin::PUSH_ANY; 00055 }
void TAO_Notify_ProxyPushSupplier::release | ( | void | ) | [private, virtual] |
TAO_Notify_Destroy_Callback methods.
Implements TAO_Notify_Refcountable.
Definition at line 22 of file ProxyPushSupplier.cpp.
friend class TAO_Notify_Builder [friend] |