diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2003-08-13 13:58:58 +0000 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2003-08-13 13:58:58 +0000 |
commit | aaecc429e3299862886073b82200aec82263c1a7 (patch) | |
tree | 56b3b1691dcfe26b992c589f66eae85863c3a68b /TAO/orbsvcs/orbsvcs/Event/ECG_Reactive_ConsumerEC_Control.cpp | |
parent | 379b413ad922f5a318b473d8770f34962d69572e (diff) | |
download | ATCD-aaecc429e3299862886073b82200aec82263c1a7.tar.gz |
ChangeLogTag: Wed Aug 13 13:54:12 UTC 2003 Johnny Willemsen <jwillemsen@remedy.nl>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/ECG_Reactive_ConsumerEC_Control.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/ECG_Reactive_ConsumerEC_Control.cpp | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/ECG_Reactive_ConsumerEC_Control.cpp b/TAO/orbsvcs/orbsvcs/Event/ECG_Reactive_ConsumerEC_Control.cpp index c51089a36bf..7ff87f3f5b6 100644 --- a/TAO/orbsvcs/orbsvcs/Event/ECG_Reactive_ConsumerEC_Control.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/ECG_Reactive_ConsumerEC_Control.cpp @@ -15,9 +15,9 @@ ACE_RCSID(Event, ECG_Reactive_ConsumerEventChannelControl, "$Id$") TAO_ECG_Reactive_ConsumerEC_Control:: TAO_ECG_Reactive_ConsumerEC_Control (const ACE_Time_Value &rate, - const ACE_Time_Value &timeout, - TAO_EC_Gateway_IIOP* gateway, - CORBA::ORB_ptr orb) + const ACE_Time_Value &timeout, + TAO_EC_Gateway_IIOP* gateway, + CORBA::ORB_ptr orb) : rate_ (rate), timeout_ (timeout), adapter_ (this), @@ -193,6 +193,7 @@ TAO_ECG_Reactive_ConsumerEC_Control::event_channel_not_exist ( ACE_DEBUG ((LM_DEBUG, "EC_Reactive_ConsumerControl(%P|%t) - " "channel %x does not exists\n")); + gateway->cleanup_consumer_ec (); gateway->cleanup_consumer_proxies (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; @@ -215,6 +216,8 @@ TAO_ECG_Reactive_ConsumerEC_Control::system_exception ( { ACE_TRY { + gateway->cleanup_consumer_ec (); + gateway->cleanup_consumer_proxies (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; |