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