#include <ProxyPushSupplier.h>
Inheritance diagram for TAO_Notify_ProxyPushSupplier:
Public Member Functions | |
TAO_Notify_ProxyPushSupplier (void) | |
Constuctor. | |
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 49 of file ProxyPushSupplier.h. |
|
Constuctor.
Definition at line 13 of file ProxyPushSupplier.cpp.
00014 { 00015 } |
|
Destructor.
Definition at line 17 of file ProxyPushSupplier.cpp.
00018 { 00019 } |
|
Definition at line 29 of file ProxyPushSupplier.cpp. References ACE_NEW_THROW_EX, TAO_Notify_ProxySupplier::connect(), TAO_Notify_PushConsumer::init(), 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 } |
|
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 } |
|
Implements TAO_Notify_Proxy. Definition at line 58 of file ProxyPushSupplier.cpp.
00059 { 00060 return "proxy_push_supplier"; 00061 } |
|
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_CString, connect_any_push_consumer(), TAO_Notify_Properties::instance(), TAO_Notify::NVPList::load(), 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 } |
|
Definition at line 52 of file ProxyPushSupplier.cpp.
00053 {
00054 return CosNotifyChannelAdmin::PUSH_ANY;
00055 }
|
|
TAO_Notify_Destroy_Callback methods.
Implements TAO_Notify_Refcountable. Definition at line 22 of file ProxyPushSupplier.cpp.
00023 { 00024 delete this; 00025 //@@ inform factory 00026 } |
|
Reimplemented from TAO_Notify_Object. Definition at line 50 of file ProxyPushSupplier.h. |