Merge branch 'PR/add-headerless-option-to-synchronize-republish' into…

… koki_s/add-xz-option-to-download-data

doc/jsk_topic_tools/scripts/synchronize_republish.rst

@@ -35,6 +35,10 @@ Parameters
 
   If ``true``, approximate synchronization is used for synchoronizing assigned topics.
 
+* ``~allow_headerless`` (Bool, Default: ``false``)
+
+  If ``true``, ``allow_headerless`` option of approximate synchronization is enabled.
+
 * ``~queue_size`` (Integer, Default: ``100``)
 
   Queue length for subscribing topics.

jsk_topic_tools/scripts/synchronize_republish.py

@@ -9,17 +9,21 @@
 def callback(*msgs):
     stamp = None
     for msg, pub in zip(msgs, pubs):
-        if stamp is None:
-            stamp = msg.header.stamp
-        else:
-            msg.header.stamp = stamp
+        try:
+            if stamp is None:
+                stamp = msg.header.stamp
+            else:
+                msg.header.stamp = stamp
+        except AttributeError:
+            pass
         pub.publish(msg)
 
 
 if __name__ == '__main__':
     rospy.init_node('synchrnoze_republish')
     topics = rospy.get_param('~topics')
     use_async = rospy.get_param('~approximate_sync', False)
+    allow_headerless = rospy.get_param('~allow_headerless', False)
     queue_size = rospy.get_param('~queue_size', 100)
     slop = rospy.get_param('~slop', 0.1)
     pubs = []
@@ -34,7 +38,7 @@ def callback(*msgs):
         subs.append(sub)
     if use_async:
         sync = message_filters.ApproximateTimeSynchronizer(
-            subs, queue_size=queue_size, slop=slop)
+            subs, queue_size=queue_size, slop=slop, allow_headerless=allow_headerless)
     else:
         sync = message_filters.TimeSynchronizer(subs, queue_size=queue_size)
     sync.registerCallback(callback)