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 | e340327f6bb7de8dc52fcea1c7e7fe81ee3914c6 (patch) | |
| tree | 56b3b1691dcfe26b992c589f66eae85863c3a68b /TAO/orbsvcs/orbsvcs/Event/ECG_Reactive_ConsumerEC_Control.cpp | |
| parent | c02b40201190e270479fd584d8e7b338d80095b8 (diff) | |
| download | ATCD-e340327f6bb7de8dc52fcea1c7e7fe81ee3914c6.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; |