def publish_to_ros2()

in workspace/src/greengrass-bridge/greengrass_bridge/app.py [0:0]

• 11 lines of code
• 2 McCabe index (conditional complexity)

    def publish_to_ros2(self, event: model.IoTCoreMessage):
        try:
            message = str(event.message.payload, "utf-8")
            topic = event.message.topic_name
            self.get_logger().info("Received message on topic %s from AWS IoT Core %s" % (message, topic))

            ros_msg = String()
            ros_msg.data = message
            self.ros_publishers[topic].publish(ros_msg)
            self.get_logger().info("Published message: %s to topic %s" % (message, topic))
        except Exception as ex:
            self.get_logger().error(str(ex))