roship_io::connection::MqttConnection Class Reference

#include <mqtt_connection.hpp>

Inheritance diagram for roship_io::connection::MqttConnection:

Collaboration diagram for roship_io::connection::MqttConnection:

Classes
struct	Params

Public Member Functions
	MqttConnection (rclcpp::Node::SharedPtr node)
void	mqttCallback (const std::vector< byte > &message, const std::string &topic)
void	sendToDevice (const io_interfaces::msg::RawPacket &msg, const std::string &topic)
void	spin_once ()
Public Member Functions inherited from roship_io::connection::IoConnection< transport::MqttClient >
	IoConnection (rclcpp::Node::SharedPtr node)

Protected Attributes
rclcpp::TimerBase::SharedPtr	timer_
std::shared_ptr< transport::MqttClient >	client_ptr_
std::map< std::string, rclcpp::Publisher< io_interfaces::msg::RawPacket >::SharedPtr >	ros_publishers_
std::map< std::string, rclcpp::Subscription< io_interfaces::msg::RawPacket >::SharedPtr >	ros_subscribers_
rclcpp::Publisher< io_interfaces::msg::RawPacket >::SharedPtr	raw_pub_
rclcpp::Subscription< io_interfaces::msg::RawPacket >::SharedPtr	raw_sub_
Params	params_
Protected Attributes inherited from roship_io::connection::IoConnection< transport::MqttClient >
rclcpp::Node::SharedPtr	node_ptr_
std::shared_ptr< transport::MqttClient >	trasnport_ptr_

Additional Inherited Members
Public Types inherited from roship_io::connection::IoConnection< transport::MqttClient >
typedef std::shared_ptr< IoConnection >	SharedPtr

Constructor & Destructor Documentation

MqttConnection()

MqttConnection::MqttConnection

(

rclcpp::Node::SharedPtr

node

)

Member Function Documentation

mqttCallback()

void MqttConnection::mqttCallback	(	const std::vector< byte > &	message,
		const std::string &	topic )

sendToDevice()

void MqttConnection::sendToDevice	(	const io_interfaces::msg::RawPacket &	msg,
		const std::string &	topic )

spin_once()

void MqttConnection::spin_once

(

)

Member Data Documentation

client_ptr_

std::shared_ptr<transport::MqttClient> roship_io::connection::MqttConnection::client_ptr_

protected

params_

Params roship_io::connection::MqttConnection::params_

protected

raw_pub_

rclcpp::Publisher<io_interfaces::msg::RawPacket>::SharedPtr roship_io::connection::MqttConnection::raw_pub_

protected

raw_sub_

rclcpp::Subscription<io_interfaces::msg::RawPacket>::SharedPtr roship_io::connection::MqttConnection::raw_sub_

protected

ros_publishers_

std::map<std::string, rclcpp::Publisher<io_interfaces::msg::RawPacket>::SharedPtr> roship_io::connection::MqttConnection::ros_publishers_

protected

ros_subscribers_

std::map<std::string, rclcpp::Subscription<io_interfaces::msg::RawPacket>::SharedPtr> roship_io::connection::MqttConnection::ros_subscribers_

protected

timer_

rclcpp::TimerBase::SharedPtr roship_io::connection::MqttConnection::timer_

protected

---

The documentation for this class was generated from the following files:

• roship_io/include/roship_io/connection/mqtt_connection.hpp
• roship_io/src/mqtt_connection.cpp