| 111 | } |
| 112 | |
| 113 | DDS::DataReader_var |
| 114 | createDataReader( |
| 115 | DDS::Subscriber_var subscriber, |
| 116 | DDS::Topic_var topic, |
| 117 | DDS::DataReaderListener_var listener) |
| 118 | { |
| 119 | // Create DataReader |
| 120 | DDS::DataReader_var reader = |
| 121 | subscriber->create_datareader(topic, |
| 122 | DATAREADER_QOS_DEFAULT, |
| 123 | listener, |
| 124 | OpenDDS::DCPS::DEFAULT_STATUS_MASK); |
| 125 | |
| 126 | // Check for failure |
| 127 | if (!reader) { |
| 128 | throw std::string("failed to create data reader"); |
| 129 | } |
| 130 | |
| 131 | return reader; |
| 132 | } |
| 133 | |
| 134 | Messenger::MessageDataWriter_var |
| 135 | narrow(DDS::DataWriter_var writer) |
no test coverage detected