48 eprosima::fastdds::dds::DomainParticipant* participant,
58 bool EnsureCreateTopic(
const std::string& channel_name);
60 std::string channel_name_;
62 std::atomic<bool> shutdown_;
65 eprosima::fastdds::dds::SubscriberListener* subscriber_listener_;
66 eprosima::fastdds::dds::DomainParticipant* participant_;
67 eprosima::fastdds::dds::Subscriber* subscriber_;
68 eprosima::fastdds::dds::Topic* topic_;
69 eprosima::fastdds::dds::DataReader* reader_;