#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) |
= CosNotifyChannelAdmin::ProxyPushConsumer methods | |
virtual void | connect_push_supplier (CosEventComm::PushSupplier_ptr push_supplier) |
virtual void | disconnect_push_consumer (void) |
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 52 of file CosEC_ProxyPushConsumer.cpp. References ACE_NEW_THROW_EX, TAO_Notify_ProxyConsumer::connect(), and TAO_Notify_PushSupplier::init().
00053 { 00054 // Convert Supplier to Base Type 00055 TAO_Notify_PushSupplier *supplier; 00056 ACE_NEW_THROW_EX (supplier, 00057 TAO_Notify_PushSupplier (this), 00058 CORBA::NO_MEMORY ()); 00059 00060 supplier->init (push_supplier); 00061 00062 this->connect (supplier); 00063 } |
|
Definition at line 66 of file CosEC_ProxyPushConsumer.cpp. References TAO_Notify_ProxyConsumer::destroy().
00067 { 00068 TAO_Notify_CosEC_ProxyPushConsumer::Ptr guard( this ); 00069 this->destroy (); 00070 } |
|
Implements TAO_Notify_Proxy. Definition at line 73 of file CosEC_ProxyPushConsumer.cpp.
00074 { 00075 return "ec_proxy_push_consumer"; 00076 } |
|
= CosNotifyChannelAdmin::ProxyPushConsumer methods
Definition at line 32 of file CosEC_ProxyPushConsumer.cpp. References TAO_Notify_Object::admin_properties(), TAO_Notify_Object::execute_task(), TAO_Notify_ProxyConsumer::is_connected(), TAO_Notify_AdminProperties::queue_full(), and TAO_Notify_AdminProperties::reject_new_events().
00033 { 00034 // Check if we should proceed at all. 00035 if (this->admin_properties().reject_new_events () == 1 00036 && this->admin_properties().queue_full ()) 00037 throw CORBA::IMP_LIMIT (); 00038 00039 if (this->is_connected () == 0) 00040 { 00041 throw CosEventComm::Disconnected (); 00042 } 00043 00044 TAO_Notify_AnyEvent_No_Copy event (any); 00045 00046 TAO_Notify_Method_Request_Lookup_No_Copy request (&event, this); 00047 00048 this->execute_task (request); 00049 } |
|
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. |