diff --git a/rc_rmq.py b/rc_rmq.py index 667518e72a6035fcd89e2fae0316a84b0e6801ca..16751f1b400fdff181ed821dcfd5824af9daf922 100644 --- a/rc_rmq.py +++ b/rc_rmq.py @@ -109,6 +109,7 @@ class RCRMQ(object): def publish_msg(self, obj): routing_key = obj.get("routing_key") + props = obj.get("props") if self._connection is None: self.connect() @@ -116,6 +117,7 @@ class RCRMQ(object): self._channel.basic_publish( exchange=self.EXCHANGE, routing_key=routing_key, + properties=props, body=json.dumps(obj["msg"]), )