diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_ProxyConsumer.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_ProxyConsumer.cpp | 18 |
1 files changed, 5 insertions, 13 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_ProxyConsumer.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_ProxyConsumer.cpp index 3f489f9540f..fdb274cb34c 100644 --- a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_ProxyConsumer.cpp +++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/FTEC_ProxyConsumer.cpp @@ -37,12 +37,9 @@ TAO_FTEC_ProxyPushConsumer::activate ( { result = RtecEventChannelAdmin::ProxyPushConsumer::_nil(); ACE_TRY { - object_id_ = Request_Context_Repository().get_object_id(ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - PortableServer::POA_var poa = _default_POA(ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + object_id_ = Request_Context_Repository().get_object_id(); + PortableServer::POA_var poa = _default_POA(); activate_object_with_id(result, poa.in(), this, id() ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; } ACE_CATCHANY { @@ -71,7 +68,6 @@ void TAO_FTEC_ProxyPushConsumer::connect_push_supplier ( update.param.connect_supplier_param(param); Inherited::connect_push_supplier(push_supplier, qos ACE_ENV_ARG_PARAMETER); - ACE_CHECK; ACE_TRY { FTRTEC::Replication_Service* svc = FTRTEC::Replication_Service::instance(); @@ -80,17 +76,15 @@ void TAO_FTEC_ProxyPushConsumer::connect_push_supplier ( svc->replicate_request(update, &FtRtecEventChannelAdmin::EventChannelFacade::disconnect_push_consumer ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; } ACE_CATCHALL { - this->disconnect_push_consumer(ACE_ENV_SINGLE_ARG_PARAMETER); + this->disconnect_push_consumer(); ACE_RE_THROW; } ACE_ENDTRY; - ACE_CHECK; } -void TAO_FTEC_ProxyPushConsumer::disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL) +void TAO_FTEC_ProxyPushConsumer::disconnect_push_consumer (void) ACE_THROW_SPEC ((CORBA::SystemException)) { if (Request_Context_Repository().is_executed_request()) @@ -99,14 +93,12 @@ void TAO_FTEC_ProxyPushConsumer::disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DE update.object_id = id(); update.param._d(FtRtecEventChannelAdmin::DISCONNECT_PUSH_CONSUMER); - Inherited::disconnect_push_consumer(ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; + Inherited::disconnect_push_consumer(); FTRTEC::Replication_Service* svc = FTRTEC::Replication_Service::instance(); ACE_Read_Guard<FTRTEC::Replication_Service> locker(*svc); svc->replicate_request(update, 0 ACE_ENV_ARG_PARAMETER); - ACE_CHECK; } void TAO_FTEC_ProxyPushConsumer::get_state(FtRtecEventChannelAdmin::ProxyPushConsumerStat& state) |