diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/Sequence_Consumer.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/Sequence_Consumer.cpp | 60 |
1 files changed, 20 insertions, 40 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/Sequence_Consumer.cpp b/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/Sequence_Consumer.cpp index 5ac22e79b8b..21a4cd4a3b2 100644 --- a/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/Sequence_Consumer.cpp +++ b/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/Sequence_Consumer.cpp @@ -75,16 +75,13 @@ Consumer_Client::parse_args (int argc, char *argv[]) static CosNotifyChannelAdmin::ConsumerAdmin_ptr -create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec - ACE_ENV_ARG_DECL) +create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec) { CosNotifyChannelAdmin::AdminID adminid = 0; CosNotifyChannelAdmin::ConsumerAdmin_var admin = ec->new_for_consumers (CosNotifyChannelAdmin::AND_OP, - adminid - ACE_ENV_ARG_PARAMETER); + adminid); - ACE_CHECK_RETURN (0); return CosNotifyChannelAdmin::ConsumerAdmin::_duplicate (admin.in ()); } @@ -92,8 +89,7 @@ create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec static void create_consumers (CosNotifyChannelAdmin::ConsumerAdmin_ptr admin, - Notify_Test_Client* client - ACE_ENV_ARG_DECL) + Notify_Test_Client* client) { // startup the first consumer Notify_Sequence_Push_Consumer* consumer_1; @@ -103,11 +99,9 @@ create_consumers (CosNotifyChannelAdmin::ConsumerAdmin_ptr admin, high, *client), CORBA::NO_MEMORY ()); - consumer_1->init(client->root_poa () ACE_ENV_ARG_PARAMETER); - ACE_CHECK; + consumer_1->init(client->root_poa ()); - consumer_1->_connect (admin ACE_ENV_ARG_PARAMETER); - ACE_CHECK; + consumer_1->_connect (admin); } // ****************************************************************** @@ -116,43 +110,35 @@ create_consumers (CosNotifyChannelAdmin::ConsumerAdmin_ptr admin, int main (int argc, char* argv[]) { - ACE_TRY_NEW_ENV + try { Consumer_Client client; - int status = client.init (argc, argv ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + int status = client.init (argc, argv); ACE_ASSERT(status == 0); ACE_UNUSED_ARG(status); CosNotifyChannelAdmin::EventChannel_var ec = - client.create_event_channel ("MyEventChannel", 1 - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + client.create_event_channel ("MyEventChannel", 1); CORBA::ORB_ptr orb = client.orb (); CORBA::Object_var object = - orb->string_to_object (ior ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + orb->string_to_object (ior); - sig_var sig = sig::_narrow (object.in () ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + sig_var sig = sig::_narrow (object.in ()); ACE_ASSERT(! CORBA::is_nil (sig.in ())); CosNotifyChannelAdmin::ConsumerAdmin_var admin = - create_consumeradmin (ec.in () ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + create_consumeradmin (ec.in ()); if (filter) { CosNotifyFilter::FilterFactory_var ffact = - ec->default_filter_factory (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + ec->default_filter_factory (); CosNotifyFilter::Filter_var filter = - ffact->create_filter ("TCL" ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + ffact->create_filter ("TCL"); ACE_ASSERT(! CORBA::is_nil(filter.in())); @@ -162,35 +148,29 @@ int main (int argc, char* argv[]) constraint_list[0].event_types.length (0); constraint_list[0].constraint_expr = CORBA::string_dup(constraintString); - filter->add_constraints (constraint_list ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + filter->add_constraints (constraint_list); admin->add_filter(filter.in()); } ACE_ASSERT (!CORBA::is_nil (admin.in ())); - create_consumers(admin.in (), &client ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + create_consumers(admin.in (), &client); // Tell the supplier to go - sig->go (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + sig->go (); - client.ORB_run( ACE_ENV_SINGLE_ARG_PARAMETER ); - ACE_TRY_CHECK; + client.ORB_run( ); ACE_DEBUG((LM_DEBUG, "Consumer done.\n")); - sig->done (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + sig->done (); return 0; } - ACE_CATCH (CORBA::Exception, e) + catch (const CORBA::Exception& e) { - ACE_PRINT_EXCEPTION (e, "Error: Consumer exception: "); + e._tao_print_exception ("Error: Consumer exception: "); } - ACE_ENDTRY; return 1; } |