diff options
author | huangming <huangminghuang@users.noreply.github.com> | 2003-11-28 04:19:40 +0000 |
---|---|---|
committer | huangming <huangminghuang@users.noreply.github.com> | 2003-11-28 04:19:40 +0000 |
commit | 9c25bdd11405a7b52bf45f9589d85e63b24fd9cf (patch) | |
tree | 8213855a38db22326d1fb312a0eca3051de23ea7 | |
parent | 504ec2cc3cb0b58f0e77cad87113150b557db055 (diff) | |
download | ATCD-9c25bdd11405a7b52bf45f9589d85e63b24fd9cf.tar.gz |
*** empty log message ***
-rw-r--r-- | TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp | 20 |
1 files changed, 11 insertions, 9 deletions
diff --git a/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp b/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp index 1c9e7e1eb69..d0c9f352019 100644 --- a/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp +++ b/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp @@ -165,15 +165,17 @@ int PushSupplier_impl::handle_timeout (const ACE_Time_Value ¤t_time, consumer_->disconnect_push_consumer(ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - ACE_CString ior("file://"); - ior += proxy_consumer_file_; - CORBA::Object_var obj = orb_->string_to_object(ior.c_str() ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK - RtecEventComm::PushConsumer_var consumer = - RtecEventComm::PushConsumer::_narrow(obj.in()); - ACE_OS::sleep(1); - consumer->push(event ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + if (proxy_consumer_file_.length()) { + ACE_CString ior("file://"); + ior += proxy_consumer_file_; + CORBA::Object_var obj = orb_->string_to_object(ior.c_str() ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + RtecEventComm::PushConsumer_var consumer = + RtecEventComm::PushConsumer::_narrow(obj.in()); + ACE_OS::sleep(1); + consumer->push(event ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + } } } ACE_CATCHANY |