This project provides the ability to publish and subscribe with Protobuf Datatypes to ROS native publishers and subscribers. So the user could work with the ROS native messages or use the Protobuf Datatypes.
#include "std_msgs/msg/string__typeadapter_protobuf_cpp.hpp"
publisher_ = this->create_publisher<std_msgs::msg::pb::String>("topic", 10);
To publish a message, it is only required to specify the protobuf message type to send the topic.
subscription2_ = this->create_subscription<std_msgs::msg::pb::String>(
"topic", 10, std::bind(&MinimalSubscriber::topic_callback2, this, _1));
void topic_callback2(const std_msgs::msg::pb::String & msg) const
{
RCLCPP_INFO(this->get_logger(), "I heard Proto: '%s'", msg.data().c_str());
}
To subscribe to the topic the user needs to specify the protobuf message type, and for the callback specify the protobuf message to hear the message received.
Another path to hear the message is using the ROS types messages:
subscription_ = this->create_subscription<std_msgs::msg::String>(
"topic", 10, std::bind(&MinimalSubscriber::topic_callback, this, _1));
void topic_callback(const std_msgs::msg::String & msg) const
{
RCLCPP_INFO(this->get_logger(), "I heard: '%s'", msg.data.c_str());
}
The following diagram shows the system to perform type-specific functions to support .msg and .proto files.
The left-hand side of the diagram shows how the .msg files are passed to the specific code generators (using vendors or rosidl_generator). The other side shows how the .proto files are passed to the code generators. Finally, the Type adapter block converter from one type to another (proto to msg, or .msg to proto), see About-Internal-Interfaces for more information.
To adapt the prototype message to a ROS type, protobuf type support generates a specialization for the proto message. The specialization has the following:
The adapted type is also registered as the default type adapter for the ros type:
The convert function must convert from one type to the other, see Type Adaptation Feature for more information.
For example, the specialization for adapting std_msgs::msg::pb::String to the std_msgs_msg::String ROS message type:
template<>
struct TypeAdapter<::std_msgs::msg::pb::String, ::std_msgs::msg::String>
{
using is_specialized = std::true_type;
using custom_type = ::std_msgs::msg::pb::String;
using ros_message_type = ::std_msgs::msg::String;
static
void
convert_to_ros_message(
const custom_type & source,
ros_message_type & destination)
{
std_msgs::msg::typesupport_protobuf_cpp::convert_to_ros(source, destination);
}
static
void
convert_to_custom(
const ros_message_type & source,
custom_type & destination)
{
std_msgs::msg::typesupport_protobuf_cpp::convert_to_proto(source, destination);
}
};
RCLCPP_USING_CUSTOM_TYPE_AS_ROS_MESSAGE_TYPE(::std_msgs::msg::pb::String, ::std_msgs::msg::String));
This adapter also mapping from IDL types to Protobuf type. IDL to Protobuf type.