diff --git a/src/ros_tcp_endpoint/subscriber.py b/src/ros_tcp_endpoint/subscriber.py index f4c42b4..070ac7f 100644 --- a/src/ros_tcp_endpoint/subscriber.py +++ b/src/ros_tcp_endpoint/subscriber.py @@ -54,7 +54,9 @@ def send(self, data): self.msg: The deserialize message """ - self.tcp_server.send_unity_message(self.topic, data) + # If Unity itself published this message, there's no need to send it back + if data._connection_header["callerid"] != self.tcp_server.node_name: + self.tcp_server.send_unity_message(self.topic, data) return self.msg def unregister(self):