in cloudwatch_metrics_collector/src/metrics_collector.cpp [67:78]
void MetricsCollector::SubscribeAllTopics()
{
ReadTopics(topics_);
for (auto & topic : topics_) {
ros::Subscriber sub = node_handle_.subscribe<ros_monitoring_msgs::MetricList>(
topic, kNodeSubQueueSize,
[this](const ros_monitoring_msgs::MetricList::ConstPtr & metric_list_msg) -> void {
this->RecordMetrics(metric_list_msg);
});
subscriptions_.push_back(sub);
}
}