in workspace/src/greengrass-bridge/greengrass_bridge/app.py [0:0]
def __init__(self):
super().__init__("greengrass_bridge")
self.declare_parameters(
namespace="",
parameters=[
("iot_topics", []),
("ros_topics", []),
("timeout", 10)
]
)
self.get_logger().info("Initializing Greengrass ROS2 Bridge...")
try:
self.iot_topics = self.get_parameter("iot_topics")._value
self.ros_topics = self.get_parameter("ros_topics")._value
except:
self.iot_topics = []
self.ros_topics = []
self.get_logger().error("Invalid ros topics / iot topics arguments.")
self.get_logger().info(" ==== ROS TOPICS ====")
self.get_logger().info(str(self.ros_topics))
self.get_logger().info(" ==== IoT TOPICS ====")
self.get_logger().info(str(self.iot_topics))
self.timeout = self.get_parameter("timeout")._value
self.get_logger().info("Timeout: %s" % self.timeout)
self.ipc_client = gg.connect()
self.init_subscribers()