#include <SequenceProxyPushSupplier.h>
Inheritance diagram for TAO_Notify_SequenceProxyPushSupplier:
Public Member Functions | |
TAO_Notify_SequenceProxyPushSupplier (void) | |
Constuctor. | |
virtual | ~TAO_Notify_SequenceProxyPushSupplier () |
Destructor. | |
virtual const char * | get_proxy_type_name (void) const |
virtual void | load_attrs (const TAO_Notify::NVPList &attrs) |
virtual CosNotifyChannelAdmin::ProxyType | MyType (void) |
= Servant methods | |
virtual void | connect_sequence_push_consumer (CosNotifyComm::SequencePushConsumer_ptr push_consumer) |
virtual void | disconnect_sequence_push_supplier () |
virtual void | release (void) |
TAO_Notify_Destroy_Callback methods. | |
Private Types | |
typedef TAO_Notify_ProxySupplier_T< POA_CosNotifyChannelAdmin::SequenceProxyPushSupplier > | SuperClass |
Friends | |
class | TAO_Notify_Builder |
Definition at line 46 of file SequenceProxyPushSupplier.h.
|
Definition at line 49 of file SequenceProxyPushSupplier.h. |
|
Constuctor.
Definition at line 13 of file SequenceProxyPushSupplier.cpp.
00014 { 00015 } |
|
Destructor.
Definition at line 17 of file SequenceProxyPushSupplier.cpp.
00018 { 00019 } |
|
Definition at line 29 of file SequenceProxyPushSupplier.cpp. References ACE_NEW_THROW_EX, TAO_Notify_ProxySupplier::connect(), TAO_Notify_SequencePushConsumer::init(), and TAO_Notify::Topology_Object::self_change(). Referenced by load_attrs().
00030 { 00031 // Convert Consumer to Base Type 00032 TAO_Notify_SequencePushConsumer* consumer; 00033 ACE_NEW_THROW_EX (consumer, 00034 TAO_Notify_SequencePushConsumer (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 SequenceProxyPushSupplier.cpp. References TAO_Notify_ProxySupplier::destroy(), and TAO_Notify::Topology_Object::self_change().
00046 { 00047 TAO_Notify_SequenceProxyPushSupplier::Ptr guard( this ); 00048 this->destroy (); 00049 this->self_change (); 00050 } |
|
Implements TAO_Notify_Proxy. Definition at line 59 of file SequenceProxyPushSupplier.cpp.
00060 { 00061 return "sequence_proxy_push_supplier"; 00062 } |
|
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 65 of file SequenceProxyPushSupplier.cpp. References ACE_CString, connect_sequence_push_consumer(), TAO_Notify_Properties::instance(), TAO_Notify::NVPList::load(), and TAO_Notify_Properties::orb().
00066 { 00067 SuperClass::load_attrs(attrs); 00068 ACE_CString ior; 00069 if (attrs.load("PeerIOR", ior)) 00070 { 00071 CORBA::ORB_var orb = TAO_Notify_PROPERTIES::instance()->orb(); 00072 try 00073 { 00074 CosNotifyComm::SequencePushConsumer_var pc = CosNotifyComm::SequencePushConsumer::_nil(); 00075 if (ior.length() > 0) 00076 { 00077 CORBA::Object_var obj = orb->string_to_object(ior.c_str()); 00078 pc = CosNotifyComm::SequencePushConsumer::_unchecked_narrow(obj.in()); 00079 } 00080 this->connect_sequence_push_consumer(pc.in()); 00081 } 00082 catch (const CORBA::Exception&) 00083 { 00084 // if we can't reconnect, tough 00085 } 00086 } 00087 } |
|
= Servant methods
Definition at line 53 of file SequenceProxyPushSupplier.cpp.
00054 {
00055 return CosNotifyChannelAdmin::PUSH_SEQUENCE;
00056 }
|
|
TAO_Notify_Destroy_Callback methods.
Implements TAO_Notify_Refcountable. Definition at line 22 of file SequenceProxyPushSupplier.cpp.
00023 { 00024 delete this; 00025 //@@ inform factory 00026 } |
|
Reimplemented from TAO_Notify_Object. Definition at line 50 of file SequenceProxyPushSupplier.h. |