Skip to content
Snippets Groups Projects
Unverified Commit f2c22647 authored by Junya Hayashi's avatar Junya Hayashi Committed by GitHub
Browse files

Merge pull request #2 from Roboauto/master

fix if frequency is none
parents 7eb2d2bd 275cd0b1
No related branches found
No related tags found
No related merge requests found
...@@ -94,7 +94,7 @@ class MqttToRosBridge(Bridge): ...@@ -94,7 +94,7 @@ class MqttToRosBridge(Bridge):
self._msg_type = msg_type self._msg_type = msg_type
self._queue_size = queue_size self._queue_size = queue_size
self._last_published = rospy.get_time() self._last_published = rospy.get_time()
self._interval = 0 if frequency is None else 1.0 / frequency self._interval = None if frequency is None else 1.0 / frequency
self._mqtt_client.subscribe(topic_from) self._mqtt_client.subscribe(topic_from)
self._mqtt_client.message_callback_add(topic_from, self._callback_mqtt) self._mqtt_client.message_callback_add(topic_from, self._callback_mqtt)
...@@ -110,7 +110,8 @@ class MqttToRosBridge(Bridge): ...@@ -110,7 +110,8 @@ class MqttToRosBridge(Bridge):
""" """
rospy.logdebug("MQTT received from {}".format(mqtt_msg.topic)) rospy.logdebug("MQTT received from {}".format(mqtt_msg.topic))
now = rospy.get_time() now = rospy.get_time()
if now - self._last_published >= self._interval:
if self._interval is None or now - self._last_published >= self._interval:
ros_msg = self._create_ros_message(mqtt_msg) ros_msg = self._create_ros_message(mqtt_msg)
self._publisher.publish(ros_msg) self._publisher.publish(ros_msg)
self._last_published = now self._last_published = now
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment