diff --git a/ros_tcp_endpoint/subscriber.py b/ros_tcp_endpoint/subscriber.py index c5b2eee..d1de6cf 100644 --- a/ros_tcp_endpoint/subscriber.py +++ b/ros_tcp_endpoint/subscriber.py @@ -44,6 +44,7 @@ def __init__(self, topic, message_class, tcp_server, queue_size=10): self.queue_size = queue_size qos_profile = QoSProfile(depth=queue_size) + qos_profile.reliability = QoSReliabilityPolicy.BEST_EFFORT # Start Subscriber listener function self.subscription = self.create_subscription(