summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2007-01-24 15:39:09 +0000
committerJohnny Willemsen <jwillemsen@remedy.nl>2007-01-24 15:39:09 +0000
commitc801f87e59c00f72bdeb5ce7bd0d276674665bac (patch)
tree70bff03d1cf156ecf05ee4c5c338d8ce423e64ee /TAO/orbsvcs/tests/Event/Mcast/Complex/supplier.cpp
parent98c0b37d4714ff774fc3ada8c9ee893c719af714 (diff)
downloadATCD-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.cpp17
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