diff options
author | huangming <huangming@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-10-15 18:07:27 +0000 |
---|---|---|
committer | huangming <huangming@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-10-15 18:07:27 +0000 |
commit | 662c4caae556d3e18e5ae5005408cd0160bc3a63 (patch) | |
tree | 61542bcbc54047e055552f487ce0ba38f4212ebe /TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_SupplierAdmin.cpp | |
parent | 428f7766fbdf80c24552dabbd4b49f241a1d055b (diff) | |
download | ATCD-662c4caae556d3e18e5ae5005408cd0160bc3a63.tar.gz |
Wed Oct 15 13:00:24 2003 Huang-Ming Huang <hh1@cse.wustl.edu>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_SupplierAdmin.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_SupplierAdmin.cpp | 50 |
1 files changed, 50 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_SupplierAdmin.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_SupplierAdmin.cpp new file mode 100644 index 00000000000..ef8111f521c --- /dev/null +++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_SupplierAdmin.cpp @@ -0,0 +1,50 @@ +// $Id$ + +#include "orbsvcs/Event/EC_ProxySupplier.h" +#include "orbsvcs/Event/EC_Event_Channel_Base.h" +#include "FTEC_SupplierAdmin.h" +#include "FTEC_ProxyConsumer.h" +#include "tao/Stub.h" + +ACE_RCSID (EventChannel, + TAO_FTEC_SupplierAdmin, + "$Id$") + + +const FtRtecEventChannelAdmin::OperationType +TAO_FTEC_SupplierAdmin::OBTAIN_ID = FtRtecEventChannelAdmin::OBTAIN_PUSH_CONSUMER; + +TAO_FTEC_SupplierAdmin::TAO_FTEC_SupplierAdmin (TAO_EC_Event_Channel_Base *ec) + : TAO_EC_SupplierAdmin (ec) + , FT_Aspect(this, this->event_channel_->supplier_poa ()) +{ +} + +TAO_FTEC_SupplierAdmin::~TAO_FTEC_SupplierAdmin() +{ +} + + +RtecEventChannelAdmin::ProxyPushConsumer_ptr +TAO_FTEC_SupplierAdmin::obtain_push_consumer (ACE_ENV_SINGLE_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + return obtain_proxy(ACE_ENV_SINGLE_ARG_PARAMETER); +} + +void +TAO_FTEC_SupplierAdmin::disconnect(RtecEventChannelAdmin::ProxyPushConsumer_ptr obj) +{ + ACE_TRY_NEW_ENV { + obj->disconnect_push_consumer(ACE_ENV_SINGLE_ARG_PARAMETER); + } + ACE_CATCHALL + { + } + ACE_ENDTRY; +} + + + + + |