diff options
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/DDS_Subscriber_Base_T.cpp')
| -rw-r--r-- | CIAO/connectors/dds4ccm/impl/DDS_Subscriber_Base_T.cpp | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/DDS_Subscriber_Base_T.cpp b/CIAO/connectors/dds4ccm/impl/DDS_Subscriber_Base_T.cpp index 30fd684e1bc..4c33709ff8c 100644 --- a/CIAO/connectors/dds4ccm/impl/DDS_Subscriber_Base_T.cpp +++ b/CIAO/connectors/dds4ccm/impl/DDS_Subscriber_Base_T.cpp @@ -76,9 +76,18 @@ DDS_Subscriber_Base_T<DDS_TYPE, CCM_TYPE, FIXED, VENDOR_TYPE>::activate ( PortStatusListener_type (status, reactor), ::CORBA::NO_MEMORY ()); } - this->data_reader_.set_listener ( - this->listener_.in (), - PortStatusListener_type::get_mask (status)); + + ::DDS::ReturnCode_t const retcode = this->data_reader_.set_listener ( + this->listener_.in (), + PortStatusListener_type::get_mask (status)); + + if (retcode != ::DDS::RETCODE_OK) + { + DDS4CCM_ERROR (DDS4CCM_LOG_LEVEL_ERROR, (LM_ERROR, CLINFO + "DDS_Subscriber_Base_T::activate - " + "Error while setting the listener on the subscriber - <%C>\n", + ::CIAO::DDS4CCM::translate_retcode (retcode))); + } } template <typename DDS_TYPE, typename CCM_TYPE, bool FIXED, DDS4CCM_Vendor VENDOR_TYPE> |