#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 () throw ( CORBA::SystemException ) |
= Servant methods | |
virtual void | connect_sequence_push_consumer (CosNotifyComm::SequencePushConsumer_ptr push_consumer) throw ( CORBA::SystemException, CosEventChannelAdmin::AlreadyConnected, CosEventChannelAdmin::TypeError ) |
virtual void | disconnect_sequence_push_supplier () throw ( CORBA::SystemException ) |
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_CHECK, ACE_ENV_ARG_PARAMETER, ACE_ENV_SINGLE_ARG_PARAMETER, ACE_NEW_THROW_EX, and TAO_Notify_SequencePushConsumer::init(). Referenced by load_attrs().
00035 { 00036 // Convert Consumer to Base Type 00037 TAO_Notify_SequencePushConsumer* consumer; 00038 ACE_NEW_THROW_EX (consumer, 00039 TAO_Notify_SequencePushConsumer (this), 00040 CORBA::NO_MEMORY ()); 00041 00042 consumer->init (push_consumer ACE_ENV_ARG_PARAMETER); 00043 ACE_CHECK; 00044 00045 this->connect (consumer ACE_ENV_ARG_PARAMETER); 00046 ACE_CHECK; 00047 this->self_change (ACE_ENV_SINGLE_ARG_PARAMETER); 00048 } |
|
Definition at line 51 of file SequenceProxyPushSupplier.cpp. References ACE_CHECK, and ACE_ENV_SINGLE_ARG_PARAMETER.
00056 { 00057 TAO_Notify_SequenceProxyPushSupplier::Ptr guard( this ); 00058 this->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); 00059 ACE_CHECK; 00060 this->self_change (ACE_ENV_SINGLE_ARG_PARAMETER); 00061 } |
|
Implements TAO_Notify_Proxy. Definition at line 73 of file SequenceProxyPushSupplier.cpp.
00074 { 00075 return "sequence_proxy_push_supplier"; 00076 } |
|
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 79 of file SequenceProxyPushSupplier.cpp. References ACE_CATCHANY, ACE_CString, ACE_DECLARE_NEW_CORBA_ENV, ACE_ENDTRY, ACE_ENV_ARG_PARAMETER, ACE_TRY, ACE_TRY_CHECK, connect_sequence_push_consumer(), TAO_Singleton< TYPE, ACE_LOCK >::instance(), and TAO_Notify::NVPList::load().
00080 { 00081 SuperClass::load_attrs(attrs); 00082 ACE_CString ior; 00083 if (attrs.load("PeerIOR", ior)) 00084 { 00085 CORBA::ORB_var orb = TAO_Notify_PROPERTIES::instance()->orb(); 00086 ACE_DECLARE_NEW_CORBA_ENV; 00087 ACE_TRY 00088 { 00089 CosNotifyComm::SequencePushConsumer_var pc = CosNotifyComm::SequencePushConsumer::_nil(); 00090 if (ior.length() > 0) 00091 { 00092 CORBA::Object_var obj = orb->string_to_object(ior.c_str() ACE_ENV_ARG_PARAMETER); 00093 ACE_TRY_CHECK; 00094 pc = CosNotifyComm::SequencePushConsumer::_unchecked_narrow(obj.in() ACE_ENV_ARG_PARAMETER); 00095 ACE_TRY_CHECK; 00096 } 00097 this->connect_sequence_push_consumer(pc.in() ACE_ENV_ARG_PARAMETER); 00098 ACE_TRY_CHECK; 00099 } 00100 ACE_CATCHANY 00101 { 00102 // if we can't reconnect, tough 00103 } 00104 ACE_ENDTRY; 00105 } 00106 } |
|
= Servant methods
Definition at line 64 of file SequenceProxyPushSupplier.cpp.
00068 {
00069 return CosNotifyChannelAdmin::PUSH_SEQUENCE;
00070 }
|
|
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. |