00001 // EC_ConsumerAdmin.cpp,v 1.32 2006/03/14 06:14:25 jtc Exp 00002 00003 #include "orbsvcs/Event/EC_ConsumerAdmin.h" 00004 #include "orbsvcs/Event/EC_ProxySupplier.h" 00005 #include "orbsvcs/Event/EC_ProxyConsumer.h" 00006 #include "orbsvcs/Event/EC_Event_Channel_Base.h" 00007 #include "orbsvcs/ESF/ESF_Peer_Workers.h" 00008 #include "orbsvcs/ESF/ESF_Peer_Admin.h" 00009 #include "orbsvcs/ESF/ESF_Shutdown_Proxy.h" 00010 00011 ACE_RCSID (Event, 00012 EC_ConsumerAdmin, 00013 "EC_ConsumerAdmin.cpp,v 1.32 2006/03/14 06:14:25 jtc Exp") 00014 00015 TAO_BEGIN_VERSIONED_NAMESPACE_DECL 00016 00017 TAO_EC_ConsumerAdmin::TAO_EC_ConsumerAdmin (TAO_EC_Event_Channel_Base *ec) 00018 : TAO_ESF_Peer_Admin<TAO_EC_Event_Channel_Base,TAO_EC_ProxyPushSupplier,RtecEventChannelAdmin::ProxyPushSupplier,TAO_EC_ProxyPushConsumer> (ec) 00019 { 00020 this->default_POA_ = 00021 this->event_channel_->consumer_poa (); 00022 } 00023 00024 TAO_EC_ConsumerAdmin::~TAO_EC_ConsumerAdmin (void) 00025 { 00026 } 00027 00028 RtecEventChannelAdmin::ProxyPushSupplier_ptr 00029 TAO_EC_ConsumerAdmin::obtain_push_supplier (ACE_ENV_SINGLE_ARG_DECL) 00030 ACE_THROW_SPEC ((CORBA::SystemException)) 00031 { 00032 return this->obtain (ACE_ENV_SINGLE_ARG_PARAMETER); 00033 } 00034 00035 PortableServer::POA_ptr 00036 TAO_EC_ConsumerAdmin::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) 00037 { 00038 return PortableServer::POA::_duplicate (this->default_POA_.in ()); 00039 } 00040 00041 TAO_END_VERSIONED_NAMESPACE_DECL