summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/examples/Notify/Lanes/Consumer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/examples/Notify/Lanes/Consumer.cpp')
-rw-r--r--TAO/orbsvcs/examples/Notify/Lanes/Consumer.cpp38
1 files changed, 14 insertions, 24 deletions
diff --git a/TAO/orbsvcs/examples/Notify/Lanes/Consumer.cpp b/TAO/orbsvcs/examples/Notify/Lanes/Consumer.cpp
index 17d2109cfb0..4ade161f36f 100644
--- a/TAO/orbsvcs/examples/Notify/Lanes/Consumer.cpp
+++ b/TAO/orbsvcs/examples/Notify/Lanes/Consumer.cpp
@@ -23,45 +23,41 @@ TAO_Notify_Lanes_Consumer::init (PortableServer::POA_var& poa, CosNotifyChannelA
this->admin_ = admin;
this->event_type_ = event_type;
- this->connect (ACE_ENV_SINGLE_ARG_PARAMETER);
+ this->connect ();
}
PortableServer::POA_ptr
-TAO_Notify_Lanes_Consumer::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+TAO_Notify_Lanes_Consumer::_default_POA (void)
{
return PortableServer::POA::_duplicate (this->default_POA_.in ());
}
void
-TAO_Notify_Lanes_Consumer::run (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+TAO_Notify_Lanes_Consumer::run (void)
{
// Nothing to do.
}
void
-TAO_Notify_Lanes_Consumer::connect (ACE_ENV_SINGLE_ARG_DECL)
+TAO_Notify_Lanes_Consumer::connect (void)
{
// Activate the consumer with the default_POA_
- CosNotifyComm::StructuredPushConsumer_var objref = this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ CosNotifyComm::StructuredPushConsumer_var objref = this->_this ();
CosNotifyChannelAdmin::ProxySupplier_var proxysupplier =
this->admin_->obtain_notification_push_supplier (CosNotifyChannelAdmin::STRUCTURED_EVENT
, proxy_supplier_id_ ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxysupplier.in ()));
// narrow
this->proxy_supplier_ =
CosNotifyChannelAdmin::StructuredProxyPushSupplier::_narrow (proxysupplier.in () ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxy_supplier_.in ()));
this->proxy_supplier_->connect_structured_push_consumer (objref.in ()
ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
// Call subscription_change to inform the supplier that this consumer is available.
CosNotification::EventTypeSeq added (1);
@@ -72,14 +68,12 @@ TAO_Notify_Lanes_Consumer::connect (ACE_ENV_SINGLE_ARG_DECL)
added[0].type_name = CORBA::string_dup (this->event_type_.c_str ());
this->proxy_supplier_->subscription_change (added, removed ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
}
void
-TAO_Notify_Lanes_Consumer::disconnect (ACE_ENV_SINGLE_ARG_DECL)
+TAO_Notify_Lanes_Consumer::disconnect (void)
{
- this->proxy_supplier_->disconnect_structured_push_supplier(ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
+ this->proxy_supplier_->disconnect_structured_push_supplier();
}
void
@@ -106,8 +100,7 @@ TAO_Notify_Lanes_Consumer::push_structured_event (const CosNotification::Structu
{
// Check the current threads priority.
RTCORBA::Priority thread_priority =
- this->orb_objects_.current_->the_priority (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
+ this->orb_objects_.current_->the_priority ();
const CosNotification::PropertySeq& prop_seq = notification.header.variable_header;
@@ -128,10 +121,10 @@ TAO_Notify_Lanes_Consumer::push_structured_event (const CosNotification::Structu
ACE_DEBUG ((LM_DEBUG, "(%P, %t) Error: Event priority and thread priority are different. \n"));
// Disconnect from the EC
- this->disconnect (ACE_ENV_SINGLE_ARG_PARAMETER);
+ this->disconnect ();
// Deactivate this object.
- this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
+ this->deactivate ();
// We received the event, shutdown the ORB.
this->orb_objects_.orb_->shutdown (1);
@@ -147,25 +140,22 @@ TAO_Notify_Lanes_Consumer::push_structured_event (const CosNotification::Structu
}
void
-TAO_Notify_Lanes_Consumer::deactivate (ACE_ENV_SINGLE_ARG_DECL)
+TAO_Notify_Lanes_Consumer::deactivate (void)
{
- PortableServer::POA_var poa (this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER));
- ACE_CHECK;
+ PortableServer::POA_var poa (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;
}
void
-TAO_Notify_Lanes_Consumer::disconnect_structured_push_consumer (ACE_ENV_SINGLE_ARG_DECL)
+TAO_Notify_Lanes_Consumer::disconnect_structured_push_consumer (void)
ACE_THROW_SPEC ((
CORBA::SystemException
))
{
- this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
+ this->deactivate ();
}