#include <CosEC_ProxyPushConsumer.h>
Inheritance diagram for TAO_Notify_CosEC_ProxyPushConsumer:
Public Member Functions | |
TAO_Notify_CosEC_ProxyPushConsumer (void) | |
Constructor. | |
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 |
Definition at line 40 of file CosEC_ProxyPushConsumer.h.
TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Notify_CosEC_ProxyPushConsumer::TAO_Notify_CosEC_ProxyPushConsumer | ( | void | ) |
TAO_Notify_CosEC_ProxyPushConsumer::~TAO_Notify_CosEC_ProxyPushConsumer | ( | ) | [virtual] |
void TAO_Notify_CosEC_ProxyPushConsumer::connect_push_supplier | ( | CosEventComm::PushSupplier_ptr | push_supplier | ) | [protected, virtual] |
Definition at line 52 of file CosEC_ProxyPushConsumer.cpp.
References ACE_NEW_THROW_EX, TAO_Notify_ProxyConsumer::connect(), and TAO_Notify_ProxyConsumer::supplier().
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 }
void TAO_Notify_CosEC_ProxyPushConsumer::disconnect_push_consumer | ( | void | ) | [protected, virtual] |
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 }
const char * TAO_Notify_CosEC_ProxyPushConsumer::get_proxy_type_name | ( | void | ) | const [virtual] |
void TAO_Notify_CosEC_ProxyPushConsumer::push | ( | const CORBA::Any & | data | ) | [protected, virtual] |
= CosNotifyChannelAdmin::ProxyPushConsumer methods
Definition at line 32 of file CosEC_ProxyPushConsumer.cpp.
References TAO_Notify_Object::admin_properties(), TAO_Notify_Object::execute_task(), and TAO_Notify_AdminProperties::queue_full().
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 }
void TAO_Notify_CosEC_ProxyPushConsumer::release | ( | void | ) | [private, virtual] |
Release.
Implements TAO_Notify_Refcountable.
Definition at line 25 of file CosEC_ProxyPushConsumer.cpp.
friend class TAO_Notify_Builder [friend] |