#include <SequenceProxyPushSupplier.h>
Inheritance diagram for TAO_Notify_SequenceProxyPushSupplier:
Public Member Functions | |
TAO_Notify_SequenceProxyPushSupplier (void) | |
Constructor. | |
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.
typedef TAO_Notify_ProxySupplier_T<POA_CosNotifyChannelAdmin::SequenceProxyPushSupplier> TAO_Notify_SequenceProxyPushSupplier::SuperClass [private] |
Definition at line 49 of file SequenceProxyPushSupplier.h.
TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Notify_SequenceProxyPushSupplier::TAO_Notify_SequenceProxyPushSupplier | ( | void | ) |
TAO_Notify_SequenceProxyPushSupplier::~TAO_Notify_SequenceProxyPushSupplier | ( | ) | [virtual] |
void TAO_Notify_SequenceProxyPushSupplier::connect_sequence_push_consumer | ( | CosNotifyComm::SequencePushConsumer_ptr | push_consumer | ) | [virtual] |
Definition at line 29 of file SequenceProxyPushSupplier.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_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 }
void TAO_Notify_SequenceProxyPushSupplier::disconnect_sequence_push_supplier | ( | ) | [virtual] |
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 }
const char * TAO_Notify_SequenceProxyPushSupplier::get_proxy_type_name | ( | void | ) | const [virtual] |
void TAO_Notify_SequenceProxyPushSupplier::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 65 of file SequenceProxyPushSupplier.cpp.
References ACE_String_Base< CHAR >::c_str(), connect_sequence_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().
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 }
CosNotifyChannelAdmin::ProxyType TAO_Notify_SequenceProxyPushSupplier::MyType | ( | void | ) | [virtual] |
= Servant methods
Definition at line 53 of file SequenceProxyPushSupplier.cpp.
References CosNotifyChannelAdmin::PUSH_SEQUENCE.
00054 { 00055 return CosNotifyChannelAdmin::PUSH_SEQUENCE; 00056 }
void TAO_Notify_SequenceProxyPushSupplier::release | ( | void | ) | [virtual] |
TAO_Notify_Destroy_Callback methods.
Implements TAO_Notify_Refcountable.
Definition at line 22 of file SequenceProxyPushSupplier.cpp.
friend class TAO_Notify_Builder [friend] |