16 #include <aws/core/utils/logging/LogMacros.h> 20 #include <kinesis_video_msgs/KinesisVideoFrame.h> 42 const kinesis_video_msgs::KinesisVideoFrame::ConstPtr & frame_msg);
46 const kinesis_video_msgs::KinesisVideoFrame::ConstPtr & frame_msg,
51 const sensor_msgs::ImageConstPtr & image);
85 rekognition_video_frame_callback)) {
86 AWS_LOG_FATAL(__func__,
"Failed to set up subscription callbacks.");
void(* KinesisVideoFrameTransportCallbackFn)(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg)
enum Aws::Kinesis::kinesis_stream_ros_input_type_e KinesisStreamRosInputType
bool SetupImageTransport(const ImageTransportCallbackFn callback)
ros::NodeHandle * handle_
RosStreamSubscriptionInstaller(ros::NodeHandle &handle)
void set_stream_manager(KinesisStreamManagerInterface *stream_manager)
std::map< std::string, ros::Publisher > publishers_
bool SetupKinesisVideoFrameTransport(const KinesisVideoFrameTransportCallbackFn callback)
void Uninstall(const std::string &topic_name) override
void(* RekognitionEnabledKinesisVideoFrameTransportCallbackFn)(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg, const ros::Publisher &publisher)
void(* ImageTransportCallbackFn)(const KinesisStreamManagerInterface &stream_manager, std::string stream_name, const sensor_msgs::ImageConstPtr &image)
kinesis_stream_ros_input_type_e
virtual bool SetDefaultCallbacks()
void RekognitionEnabledKinesisVideoFrameTransportCallback(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg, const ros::Publisher &publisher)
Aws::Kinesis::KinesisStreamManagerInterface * stream_manager_
void KinesisVideoFrameTransportCallback(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg)
void ImageTransportCallback(const KinesisStreamManagerInterface &stream_manager, std::string stream_name, const sensor_msgs::ImageConstPtr &image)
std::vector< ros::Subscriber > standard_subscribers_
std::vector< image_transport::Subscriber > image_transport_subscribers_
bool SetupRekognitionEnabledKinesisVideoFrameTransport(const RekognitionEnabledKinesisVideoFrameTransportCallbackFn callback)