def execute_publish_thread()

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


    def execute_publish_thread(self, event: model.IoTCoreMessage):
        try:
            self.get_logger().info("Kicking off the thread.")
            t = threading.Thread(target = self.publish_to_ros2, args=[event])
            t.start()
        except Exception as ex:
            self.get_logger().error(str(ex))