#include <StructuredProxyPushSupplier.h>
Inheritance diagram for TAO_Notify_StructuredProxyPushSupplier:
Public Member Functions | |
TAO_Notify_StructuredProxyPushSupplier (void) | |
Constuctor. | |
virtual | ~TAO_Notify_StructuredProxyPushSupplier () |
Destructor. | |
virtual void | load_attrs (const TAO_Notify::NVPList &attrs) |
virtual CosNotifyChannelAdmin::ProxyType | MyType () throw ( CORBA::SystemException ) |
= Servant methods | |
virtual void | connect_structured_push_consumer (CosNotifyComm::StructuredPushConsumer_ptr push_consumer) throw ( CORBA::SystemException, CosEventChannelAdmin::AlreadyConnected, CosEventChannelAdmin::TypeError ) |
virtual void | disconnect_structured_push_supplier () throw ( CORBA::SystemException ) |
virtual const char * | get_proxy_type_name (void) const |
Private Types | |
typedef TAO_Notify_ProxySupplier_T< POA_Event_Forwarder::StructuredProxyPushSupplier > | SuperClass |
Private Member Functions | |
virtual void | release (void) |
Release. | |
Friends | |
class | TAO_Notify_Builder |
Definition at line 47 of file StructuredProxyPushSupplier.h.
|
Definition at line 50 of file StructuredProxyPushSupplier.h. |
|
Constuctor.
Definition at line 16 of file StructuredProxyPushSupplier.cpp.
00017 { 00018 } |
|
Destructor.
Definition at line 20 of file StructuredProxyPushSupplier.cpp.
00021 { 00022 } |
|
Definition at line 41 of file StructuredProxyPushSupplier.cpp. References ACE_CHECK, ACE_ENV_ARG_PARAMETER, ACE_ENV_SINGLE_ARG_PARAMETER, ACE_NEW_THROW_EX, and TAO_Notify_StructuredPushConsumer::init(). Referenced by load_attrs().
00047 { 00048 // Convert Consumer to Base Type 00049 TAO_Notify_StructuredPushConsumer* consumer; 00050 ACE_NEW_THROW_EX (consumer, 00051 TAO_Notify_StructuredPushConsumer (this), 00052 CORBA::NO_MEMORY ()); 00053 00054 consumer->init (push_consumer ACE_ENV_ARG_PARAMETER); 00055 ACE_CHECK; 00056 00057 this->connect (consumer ACE_ENV_ARG_PARAMETER); 00058 ACE_CHECK; 00059 this->self_change (ACE_ENV_SINGLE_ARG_PARAMETER); 00060 } |
|
Definition at line 63 of file StructuredProxyPushSupplier.cpp. References ACE_CHECK, and ACE_ENV_SINGLE_ARG_PARAMETER.
00068 { 00069 TAO_Notify_StructuredProxyPushSupplier::Ptr guard( this ); 00070 this->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); 00071 ACE_CHECK; 00072 this->self_change (ACE_ENV_SINGLE_ARG_PARAMETER); 00073 } |
|
Implements TAO_Notify_Proxy. Definition at line 76 of file StructuredProxyPushSupplier.cpp.
00077 { 00078 return "structured_proxy_push_supplier"; 00079 } |
|
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 82 of file StructuredProxyPushSupplier.cpp. References ACE_CATCHANY, ACE_CString, ACE_DECLARE_NEW_CORBA_ENV, ACE_ENDTRY, ACE_ENV_ARG_PARAMETER, ACE_TRY, ACE_TRY_CHECK, connect_structured_push_consumer(), TAO_Singleton< TYPE, ACE_LOCK >::instance(), and TAO_Notify::NVPList::load().
00083 { 00084 SuperClass::load_attrs(attrs); 00085 ACE_CString ior; 00086 if (attrs.load("PeerIOR", ior)) 00087 { 00088 CORBA::ORB_var orb = TAO_Notify_PROPERTIES::instance()->orb(); 00089 ACE_DECLARE_NEW_CORBA_ENV; 00090 ACE_TRY 00091 { 00092 CosNotifyComm::StructuredPushConsumer_var pc = CosNotifyComm::StructuredPushConsumer::_nil(); 00093 if (ior.length() > 0) 00094 { 00095 CORBA::Object_var obj = orb->string_to_object(ior.c_str() ACE_ENV_ARG_PARAMETER); 00096 ACE_TRY_CHECK; 00097 pc = CosNotifyComm::StructuredPushConsumer::_unchecked_narrow(obj.in() ACE_ENV_ARG_PARAMETER); 00098 ACE_TRY_CHECK; 00099 } 00100 this->connect_structured_push_consumer(pc.in() ACE_ENV_ARG_PARAMETER); 00101 ACE_TRY_CHECK; 00102 } 00103 ACE_CATCHANY 00104 { 00105 // if we can't connect... tough 00106 } 00107 ACE_ENDTRY; 00108 } 00109 } |
|
= Servant methods
Definition at line 32 of file StructuredProxyPushSupplier.cpp.
00036 {
00037 return CosNotifyChannelAdmin::PUSH_STRUCTURED;
00038 }
|
|
Release.
Implements TAO_Notify_Refcountable. Definition at line 25 of file StructuredProxyPushSupplier.cpp.
00026 { 00027 delete this; 00028 //@@ inform factory 00029 } |
|
Reimplemented from TAO_Notify_Object. Definition at line 51 of file StructuredProxyPushSupplier.h. |