diff options
Diffstat (limited to 'trunk/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.cpp')
-rw-r--r-- | trunk/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.cpp | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.cpp b/trunk/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.cpp new file mode 100644 index 00000000000..73bf25fff47 --- /dev/null +++ b/trunk/TAO/orbsvcs/orbsvcs/Event/EC_ConsumerAdmin.cpp @@ -0,0 +1,41 @@ +// $Id$ + +#include "orbsvcs/Event/EC_ConsumerAdmin.h" +#include "orbsvcs/Event/EC_ProxySupplier.h" +#include "orbsvcs/Event/EC_ProxyConsumer.h" +#include "orbsvcs/Event/EC_Event_Channel_Base.h" +#include "orbsvcs/ESF/ESF_Peer_Workers.h" +#include "orbsvcs/ESF/ESF_Peer_Admin.h" +#include "orbsvcs/ESF/ESF_Shutdown_Proxy.h" + +ACE_RCSID (Event, + EC_ConsumerAdmin, + "$Id$") + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +TAO_EC_ConsumerAdmin::TAO_EC_ConsumerAdmin (TAO_EC_Event_Channel_Base *ec) + : TAO_ESF_Peer_Admin<TAO_EC_Event_Channel_Base,TAO_EC_ProxyPushSupplier,RtecEventChannelAdmin::ProxyPushSupplier,TAO_EC_ProxyPushConsumer> (ec) +{ + this->default_POA_ = + this->event_channel_->consumer_poa (); +} + +TAO_EC_ConsumerAdmin::~TAO_EC_ConsumerAdmin (void) +{ +} + +RtecEventChannelAdmin::ProxyPushSupplier_ptr +TAO_EC_ConsumerAdmin::obtain_push_supplier (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + return this->obtain (ACE_ENV_SINGLE_ARG_PARAMETER); +} + +PortableServer::POA_ptr +TAO_EC_ConsumerAdmin::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) +{ + return PortableServer::POA::_duplicate (this->default_POA_.in ()); +} + +TAO_END_VERSIONED_NAMESPACE_DECL |