summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/Sequence_Multi_Filter/Sequence_Consumer.cpp
diff options
context:
space:
mode:
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.cpp60
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;
}