diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2007-01-24 15:39:09 +0000 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2007-01-24 15:39:09 +0000 |
commit | c801f87e59c00f72bdeb5ce7bd0d276674665bac (patch) | |
tree | 70bff03d1cf156ecf05ee4c5c338d8ce423e64ee /TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp | |
parent | 98c0b37d4714ff774fc3ada8c9ee893c719af714 (diff) | |
download | ATCD-c801f87e59c00f72bdeb5ce7bd0d276674665bac.tar.gz |
Wed Jan 24 14:00:12 UTC 2007 Johnny Willemsen <jwillemsen@remedy.nl>
Diffstat (limited to 'TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp | 17 |
1 files changed, 3 insertions, 14 deletions
diff --git a/TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp b/TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp index ab13f1a28ef..0d93222b9ea 100644 --- a/TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp +++ b/TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp @@ -23,15 +23,12 @@ send_events (RtecEventChannelAdmin::ProxyPushConsumer_ptr consumer // Send 1 event of each type. events[0].header.type = A_EVENT_TYPE; consumer->push (events ACE_ENV_ARG_PARAMETER); - ACE_CHECK; events[0].header.type = B_EVENT_TYPE; consumer->push (events ACE_ENV_ARG_PARAMETER); - ACE_CHECK; events[0].header.type = C_EVENT_TYPE; consumer->push (events ACE_ENV_ARG_PARAMETER); - ACE_CHECK; } } @@ -62,7 +59,6 @@ main (int argc, char *argv[]) // Initialize ORB and parse args. CORBA::ORB_var orb = CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; if (parse_args (argc, argv) == -1) return 1; @@ -70,23 +66,19 @@ main (int argc, char *argv[]) // Obtain reference to EC. CORBA::Object_var obj = orb->resolve_initial_references ("Event_Service" ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; RtecEventChannelAdmin::EventChannel_var ec = RtecEventChannelAdmin::EventChannel::_narrow (obj.in () ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; if (check_for_nil (ec.in (), "EC") == -1) return 1; // Obtain reference to SupplierAdmin. RtecEventChannelAdmin::SupplierAdmin_var supplier_admin = - ec->for_suppliers (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + ec->for_suppliers (); // Obtain ProxyPushConsumer and connect this supplier. RtecEventChannelAdmin::ProxyPushConsumer_var consumer = - supplier_admin->obtain_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + supplier_admin->obtain_push_consumer (); ACE_SupplierQOS_Factory qos; qos.insert (SOURCE_ID, A_EVENT_TYPE, 0, 1); @@ -97,15 +89,12 @@ main (int argc, char *argv[]) (RtecEventComm::PushSupplier::_nil (), qos.get_SupplierQOS () ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; // Send events to EC. send_events (consumer.in () ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; // Tell EC to shut down. - ec->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + ec->destroy (); } ACE_CATCHANY |