summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/examples/RtEC/MCast/Supplier.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/examples/RtEC/MCast/Supplier.cpp')
-rw-r--r--TAO/orbsvcs/examples/RtEC/MCast/Supplier.cpp44
1 files changed, 16 insertions, 28 deletions
diff --git a/TAO/orbsvcs/examples/RtEC/MCast/Supplier.cpp b/TAO/orbsvcs/examples/RtEC/MCast/Supplier.cpp
index f835dcb6daa..205518d540d 100644
--- a/TAO/orbsvcs/examples/RtEC/MCast/Supplier.cpp
+++ b/TAO/orbsvcs/examples/RtEC/MCast/Supplier.cpp
@@ -13,16 +13,13 @@ Supplier::Supplier (void)
}
void
-Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin
- ACE_ENV_ARG_DECL)
+Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin)
{
this->proxy_ =
- supplier_admin->obtain_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ supplier_admin->obtain_push_consumer ();
RtecEventComm::PushSupplier_var me =
- this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ this->_this ();
// Simple publication, but usually the helper classes in
// $TAO_ROOT/orbsvcs/Event_Utils.h are a better way to do this.
@@ -35,39 +32,32 @@ Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin
h0.type = ACE_ES_EVENT_UNDEFINED; // first free event type
h0.source = 1; // first free event source
- this->proxy_->connect_push_supplier (me.in (), qos
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ this->proxy_->connect_push_supplier (me.in (), qos);
}
void
-Supplier::disconnect (ACE_ENV_SINGLE_ARG_DECL)
+Supplier::disconnect (void)
{
// Disconnect from the EC
- ACE_TRY
+ try
{
- this->proxy_->disconnect_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->proxy_->disconnect_push_consumer ();
}
- ACE_CATCHANY
+ catch (const CORBA::Exception&)
{
}
- ACE_ENDTRY;
PortableServer::POA_var poa =
- this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ this->_default_POA ();
PortableServer::ObjectId_var id =
- poa->servant_to_id (this ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- poa->deactivate_object (id.in () ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
+ poa->servant_to_id (this);
+ poa->deactivate_object (id.in ());
}
void
-Supplier::perform_push (ACE_ENV_SINGLE_ARG_DECL)
+Supplier::perform_push (void)
{
- ACE_TRY
+ try
{
// The event type and source must match our publications
RtecEventComm::EventSet event (1);
@@ -77,17 +67,15 @@ Supplier::perform_push (ACE_ENV_SINGLE_ARG_DECL)
// Avoid loops throught the event channel federations
event[0].header.ttl = 1;
- this->proxy_->push (event ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->proxy_->push (event);
}
- ACE_CATCHANY
+ catch (const CORBA::Exception&)
{
}
- ACE_ENDTRY;
}
void
-Supplier::disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+Supplier::disconnect_push_supplier (void)
ACE_THROW_SPEC ((CORBA::SystemException))
{
}