#include <PushSupplier.h>
Inheritance diagram for TAO_Notify_PushSupplier:


Public Member Functions | |
| TAO_Notify_PushSupplier (TAO_Notify_ProxyConsumer *proxy) | |
| Constuctor. | |
| virtual | ~TAO_Notify_PushSupplier () |
| Destructor. | |
| void | init (CosEventComm::PushSupplier_ptr push_supplier) |
| Init. | |
| virtual ACE_CString | get_ior (void) const |
| Retrieve the ior of this peer. | |
Protected Attributes | |
| CosEventComm::PushSupplier_var | push_supplier_ |
| The Supplier. | |
Private Member Functions | |
| virtual void | release (void) |
| TAO_Notify_Destroy_Callback methods. | |
|
|
Constuctor.
Definition at line 10 of file PushSupplier.cpp.
00011 :TAO_Notify_Supplier (proxy) 00012 { 00013 } |
|
|
Destructor.
Definition at line 15 of file PushSupplier.cpp.
00016 {
00017 }
|
|
|
Retrieve the ior of this peer.
Implements TAO_Notify_Peer. Definition at line 46 of file PushSupplier.cpp. References ACE_CATCHANY, ACE_CString, ACE_DECLARE_NEW_CORBA_ENV, ACE_ENDTRY, ACE_ENV_ARG_PARAMETER, ACE_TRY, ACE_TRY_CHECK, and TAO_Singleton< TYPE, ACE_LOCK >::instance().
00047 {
00048 ACE_CString result;
00049 CORBA::ORB_var orb = TAO_Notify_PROPERTIES::instance()->orb();
00050 ACE_DECLARE_NEW_CORBA_ENV;
00051 ACE_TRY
00052 {
00053 CORBA::String_var ior = orb->object_to_string(this->push_supplier_.in() ACE_ENV_ARG_PARAMETER);
00054 ACE_TRY_CHECK;
00055 result = static_cast<const char*> (ior.in ());
00056 }
00057 ACE_CATCHANY
00058 {
00059 result.fast_clear();
00060 }
00061 ACE_ENDTRY;
00062 return result;
00063 }
|
|
|
Init.
Definition at line 20 of file PushSupplier.cpp. References ACE_CATCHANY, ACE_ENDTRY, ACE_ENV_ARG_PARAMETER, ACE_TRY, ACE_TRY_CHECK, and push_supplier_. Referenced by TAO_Notify_ProxyPushConsumer::connect_any_push_supplier(), and TAO_Notify_CosEC_ProxyPushConsumer::connect_push_supplier().
00021 {
00022 // TODO: verify single init call
00023 // push_supplier is optional
00024 this->push_supplier_ = CosEventComm::PushSupplier::_duplicate (push_supplier);
00025
00026 ACE_TRY
00027 {
00028 this->subscribe_ = CosNotifyComm::NotifySubscribe::_narrow (push_supplier ACE_ENV_ARG_PARAMETER);
00029 ACE_TRY_CHECK;
00030 }
00031 ACE_CATCHANY
00032 {
00033 // _narrow failed which probably means the interface is CosEventComm type.
00034 }
00035 ACE_ENDTRY;
00036 }
|
|
|
TAO_Notify_Destroy_Callback methods.
Implements TAO_Notify_Peer. Definition at line 39 of file PushSupplier.cpp.
00040 {
00041 delete this;
00042 //@@ inform factory
00043 }
|
|
|
The Supplier.
Definition at line 53 of file PushSupplier.h. Referenced by init(). |
1.3.6