#include <CosEC_ProxyPushConsumer.h>
Inheritance diagram for TAO_Notify_CosEC_ProxyPushConsumer:
Public Member Functions | |
TAO_Notify_CosEC_ProxyPushConsumer (void) | |
Constuctor. | |
virtual | ~TAO_Notify_CosEC_ProxyPushConsumer () |
Destructor. | |
virtual const char * | get_proxy_type_name (void) const |
Protected Member Functions | |
virtual void | push (const CORBA::Any &data) throw ( CORBA::SystemException, CosEventComm::Disconnected ) |
= CosNotifyChannelAdmin::ProxyPushConsumer methods | |
virtual void | connect_push_supplier (CosEventComm::PushSupplier_ptr push_supplier) throw ( CORBA::SystemException, CosEventChannelAdmin::AlreadyConnected ) |
virtual void | disconnect_push_consumer () throw ( CORBA::SystemException ) |
Private Member Functions | |
virtual void | release (void) |
Release. | |
Friends | |
class | TAO_Notify_Builder |
|
Constuctor.
Definition at line 16 of file CosEC_ProxyPushConsumer.cpp.
00017 { 00018 } |
|
Destructor.
Definition at line 20 of file CosEC_ProxyPushConsumer.cpp.
00021 { 00022 } |
|
Definition at line 56 of file CosEC_ProxyPushConsumer.cpp. References ACE_CHECK, ACE_ENV_ARG_PARAMETER, ACE_NEW_THROW_EX, and TAO_Notify_PushSupplier::init().
00061 { 00062 // Convert Supplier to Base Type 00063 TAO_Notify_PushSupplier *supplier; 00064 ACE_NEW_THROW_EX (supplier, 00065 TAO_Notify_PushSupplier (this), 00066 CORBA::NO_MEMORY ()); 00067 00068 supplier->init (push_supplier ACE_ENV_ARG_PARAMETER); 00069 ACE_CHECK; 00070 00071 this->connect (supplier ACE_ENV_ARG_PARAMETER); 00072 } |
|
Definition at line 75 of file CosEC_ProxyPushConsumer.cpp. References ACE_ENV_SINGLE_ARG_PARAMETER.
00079 { 00080 TAO_Notify_CosEC_ProxyPushConsumer::Ptr guard( this ); 00081 this->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); 00082 } |
|
Implements TAO_Notify_Proxy. Definition at line 85 of file CosEC_ProxyPushConsumer.cpp.
00086 { 00087 return "ec_proxy_push_consumer"; 00088 } |
|
= CosNotifyChannelAdmin::ProxyPushConsumer methods
Definition at line 32 of file CosEC_ProxyPushConsumer.cpp. References ACE_ENV_ARG_PARAMETER, and ACE_THROW.
00037 { 00038 // Check if we should proceed at all. 00039 if (this->admin_properties().reject_new_events () == 1 00040 && this->admin_properties().queue_full ()) 00041 ACE_THROW (CORBA::IMP_LIMIT ()); 00042 00043 if (this->is_connected () == 0) 00044 { 00045 ACE_THROW (CosEventComm::Disconnected ()); 00046 } 00047 00048 TAO_Notify_AnyEvent_No_Copy event (any); 00049 00050 TAO_Notify_Method_Request_Lookup_No_Copy request (&event, this); 00051 00052 this->execute_task (request ACE_ENV_ARG_PARAMETER); 00053 } |
|
Release.
Implements TAO_Notify_Refcountable. Definition at line 25 of file CosEC_ProxyPushConsumer.cpp.
00026 { 00027 delete this; 00028 //@@ inform factory 00029 } |
|
Reimplemented from TAO_Notify_Object. Definition at line 43 of file CosEC_ProxyPushConsumer.h. |