TAO_CosEvent: CEC_SupplierAdmin.cpp Source File

00001 // CEC_SupplierAdmin.cpp,v 1.14 2006/03/14 06:14:25 jtc Exp
00002 
00003 #include "orbsvcs/CosEvent/CEC_SupplierAdmin.h"
00004 #include "orbsvcs/CosEvent/CEC_ProxyPushConsumer.h"
00005 #include "orbsvcs/CosEvent/CEC_ProxyPullConsumer.h"
00006 #include "orbsvcs/CosEvent/CEC_EventChannel.h"
00007 #include "orbsvcs/ESF/ESF_Shutdown_Proxy.h"
00008 
00009 #if ! defined (__ACE_INLINE__)
00010 #include "orbsvcs/CosEvent/CEC_SupplierAdmin.i"
00011 #endif /* __ACE_INLINE__ */
00012 
00013 ACE_RCSID (CosEvent,
00014            CEC_SupplierAdmin,
00015            "CEC_SupplierAdmin.cpp,v 1.14 2006/03/14 06:14:25 jtc Exp")
00016 
00017 
00018 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
00019 
00020 TAO_CEC_SupplierAdmin::TAO_CEC_SupplierAdmin (TAO_CEC_EventChannel *ec)
00021   :  event_channel_ (ec),
00022      push_admin_ (ec),
00023      pull_admin_ (ec)
00024 {
00025   this->default_POA_ =
00026     this->event_channel_->supplier_poa ();
00027 }
00028 
00029 TAO_CEC_SupplierAdmin::~TAO_CEC_SupplierAdmin (void)
00030 {
00031 }
00032 
00033 PortableServer::POA_ptr
00034 TAO_CEC_SupplierAdmin::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
00035 {
00036   return PortableServer::POA::_duplicate (this->default_POA_.in ());
00037 }
00038 
00039 void
00040 TAO_CEC_SupplierAdmin::connected (TAO_CEC_ProxyPushConsumer *consumer
00041                                   ACE_ENV_ARG_DECL)
00042 {
00043   this->push_admin_.connected (consumer ACE_ENV_ARG_PARAMETER);
00044 }
00045 
00046 void
00047 TAO_CEC_SupplierAdmin::reconnected (TAO_CEC_ProxyPushConsumer *consumer
00048                                     ACE_ENV_ARG_DECL)
00049 {
00050   this->push_admin_.reconnected (consumer ACE_ENV_ARG_PARAMETER);
00051 }
00052 
00053 void
00054 TAO_CEC_SupplierAdmin::disconnected (TAO_CEC_ProxyPushConsumer *consumer
00055                                      ACE_ENV_ARG_DECL)
00056 {
00057   this->push_admin_.disconnected (consumer ACE_ENV_ARG_PARAMETER);
00058 }
00059 
00060 void
00061 TAO_CEC_SupplierAdmin::connected (TAO_CEC_ProxyPullConsumer *consumer
00062                                   ACE_ENV_ARG_DECL)
00063 {
00064   this->pull_admin_.connected (consumer ACE_ENV_ARG_PARAMETER);
00065 }
00066 
00067 void
00068 TAO_CEC_SupplierAdmin::reconnected (TAO_CEC_ProxyPullConsumer *consumer
00069                                     ACE_ENV_ARG_DECL)
00070 {
00071   this->pull_admin_.reconnected (consumer ACE_ENV_ARG_PARAMETER);
00072 }
00073 
00074 void
00075 TAO_CEC_SupplierAdmin::disconnected (TAO_CEC_ProxyPullConsumer *consumer
00076                                      ACE_ENV_ARG_DECL)
00077 {
00078   this->pull_admin_.disconnected (consumer ACE_ENV_ARG_PARAMETER);
00079 }
00080 
00081 void
00082 TAO_CEC_SupplierAdmin::shutdown (ACE_ENV_SINGLE_ARG_DECL)
00083 {
00084   this->push_admin_.shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
00085   ACE_CHECK;
00086 
00087   this->pull_admin_.shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
00088   ACE_CHECK;
00089 }
00090 
00091 CosEventChannelAdmin::ProxyPushConsumer_ptr
00092 TAO_CEC_SupplierAdmin::obtain_push_consumer (ACE_ENV_SINGLE_ARG_DECL)
00093     ACE_THROW_SPEC ((CORBA::SystemException))
00094 {
00095   return this->push_admin_.obtain (ACE_ENV_SINGLE_ARG_PARAMETER);
00096 }
00097 
00098 CosEventChannelAdmin::ProxyPullConsumer_ptr
00099 TAO_CEC_SupplierAdmin::obtain_pull_consumer (ACE_ENV_SINGLE_ARG_DECL)
00100     ACE_THROW_SPEC ((CORBA::SystemException))
00101 {
00102   return this->pull_admin_.obtain (ACE_ENV_SINGLE_ARG_PARAMETER);
00103 }
00104 
00105 TAO_END_VERSIONED_NAMESPACE_DECL