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