| 95 | } |
| 96 | |
| 97 | DDS::Subscriber* |
| 98 | OpenDDS::Model::Delegate::createSubscriber( |
| 99 | DDS::DomainParticipant* participant, |
| 100 | const DDS::SubscriberQos& subscriberQos, |
| 101 | DDS::StatusMask mask, |
| 102 | const OPENDDS_STRING& transportConfig) |
| 103 | { |
| 104 | DDS::Subscriber* subscriber |
| 105 | = participant->create_subscriber( |
| 106 | subscriberQos, |
| 107 | DDS::SubscriberListener::_nil(), |
| 108 | mask |
| 109 | ); |
| 110 | if( !subscriber) { |
| 111 | return 0; |
| 112 | } |
| 113 | |
| 114 | // If the modeler specified a transport config, bind to it |
| 115 | if (!transportConfig.empty()) { |
| 116 | try { |
| 117 | TheTransportRegistry->bind_config(transportConfig, subscriber); |
| 118 | } catch (OpenDDS::DCPS::Transport::Exception&) { |
| 119 | participant->delete_subscriber(subscriber); |
| 120 | return 0; |
| 121 | } |
| 122 | } |
| 123 | |
| 124 | return subscriber; |
| 125 | } |
| 126 | |
| 127 | DDS::DataWriter* |
| 128 | OpenDDS::Model::Delegate::createPublication( |
no test coverage detected