summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushSupplier.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushSupplier.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushSupplier.cpp35
1 files changed, 13 insertions, 22 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushSupplier.cpp b/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushSupplier.cpp
index d478b3253cc..93774bb543a 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushSupplier.cpp
+++ b/TAO/orbsvcs/orbsvcs/Notify/Any/ProxyPushSupplier.cpp
@@ -26,8 +26,7 @@ TAO_Notify_ProxyPushSupplier::release (void)
}
void
-TAO_Notify_ProxyPushSupplier::connect_any_push_consumer (CosEventComm::PushConsumer_ptr push_consumer
- ACE_ENV_ARG_DECL)
+TAO_Notify_ProxyPushSupplier::connect_any_push_consumer (CosEventComm::PushConsumer_ptr push_consumer)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosEventChannelAdmin::AlreadyConnected,
@@ -40,28 +39,25 @@ TAO_Notify_ProxyPushSupplier::connect_any_push_consumer (CosEventComm::PushConsu
TAO_Notify_PushConsumer (this),
CORBA::NO_MEMORY ());
- consumer->init (push_consumer ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ consumer->init (push_consumer);
- this->connect (consumer ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- this->self_change (ACE_ENV_SINGLE_ARG_PARAMETER);
+ this->connect (consumer);
+ this->self_change ();
}
void
-TAO_Notify_ProxyPushSupplier::disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL)
+TAO_Notify_ProxyPushSupplier::disconnect_push_supplier (void)
ACE_THROW_SPEC ((
CORBA::SystemException
))
{
TAO_Notify_ProxyPushSupplier::Ptr guard( this );
- this->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
- this->self_change (ACE_ENV_SINGLE_ARG_PARAMETER);
+ this->destroy ();
+ this->self_change ();
}
CosNotifyChannelAdmin::ProxyType
-TAO_Notify_ProxyPushSupplier::MyType (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+TAO_Notify_ProxyPushSupplier::MyType (void)
ACE_THROW_SPEC ((
CORBA::SystemException
))
@@ -83,27 +79,22 @@ TAO_Notify_ProxyPushSupplier::load_attrs (const TAO_Notify::NVPList& attrs)
if (attrs.load("PeerIOR", ior))
{
CORBA::ORB_var orb = TAO_Notify_PROPERTIES::instance()->orb();
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
+ try
{
CosNotifyComm::PushConsumer_var pc =
CosNotifyComm::PushConsumer::_nil();
if (ior.length() > 0)
{
CORBA::Object_var obj =
- orb->string_to_object(ior.c_str() ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
- pc = CosNotifyComm::PushConsumer::_unchecked_narrow(obj.in() ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ orb->string_to_object(ior.c_str());
+ pc = CosNotifyComm::PushConsumer::_unchecked_narrow(obj.in());
}
- this->connect_any_push_consumer(pc.in() ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->connect_any_push_consumer(pc.in());
}
- ACE_CATCHANY
+ catch (const CORBA::Exception&)
{
// if we can't reconnect, tough...
}
- ACE_ENDTRY;
}
}