[utils] Implement helper method to ensure send_multipart gets the right inputs

beat/core/utils.py

@@ -64,3 +64,16 @@ def uniq(seq):
         result.append(item)
 
     return result
+
+
+def send_multipart(socket, parts):
+    """
+    Send the parts through the socket after having encoded them if
+    necessary.
+    """
+
+    for index, item in enumerate(parts):
+        if isinstance(item, six.string_types):
+            parts[index] = item.encode('utf-8')
+
+    socket.send_multipart(parts)