Class RMW_Connext_Publisher

• Defined in File rmw_impl.hpp

Class Documentation

class RMW_Connext_Publisher

Public Functions

rmw_ret_t finalize()

inline DDS_DataWriter *writer() const

inline RMW_Connext_MessageTypeSupport *message_type_support() const

inline DDS_InstanceHandle_t instance_handle()

rmw_ret_t write(const void *const ros_message, const bool serialized, int64_t *const sn_out = nullptr)

inline rmw_ret_t enable() const

inline RMW_Connext_PublisherStatusCondition *condition()

inline const rmw_gid_t *gid() const

size_t subscriptions_count()

rmw_ret_t assert_liveliness()

rmw_ret_t wait_for_all_acked(rmw_time_t wait_timeout)

rmw_ret_t qos(rmw_qos_profile_t *const qos)

rmw_ret_t requestreply_header_to_dds(const RMW_Connext_RequestReplyMessage *const rr_msg, DDS_SampleIdentity_t *const sample_identity, DDS_SampleIdentity_t *const related_sample_identity)

inline DDS_Topic *dds_topic() const

inline DDS_Publisher *dds_publisher() const

inline DDS_DomainParticipant *dds_participant() const

Public Static Functions

static RMW_Connext_Publisher *create(rmw_context_impl_t *const ctx, DDS_DomainParticipant *const dp, DDS_Publisher *const pub, const rosidl_message_type_support_t *const type_supports, const char *const topic_name, const rmw_qos_profile_t *const qos_policies, const rmw_publisher_options_t *const publisher_options, const bool internal = false, const RMW_Connext_MessageType msg_type = RMW_CONNEXT_MESSAGE_USERDATA, const void *const intro_members = nullptr, const bool intro_members_cpp = false, std::string *const type_name = nullptr)