#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. |
1.3.6