From 9e2f78c299a5644bb85d813f692c611c68f226a9 Mon Sep 17 00:00:00 2001
From: Bo-Chun Louis Chen <louistw@uab.edu>
Date: Thu, 24 Mar 2022 20:53:48 -0500
Subject: [PATCH] Add properties support when publish msg
---
rc_rmq.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/rc_rmq.py b/rc_rmq.py
index 667518e..16751f1 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"]),
)
--
GitLab