add msg id validation

idanasulin2706 · idanasulin2706 · commit d6658dc4ba50 · 2023-05-14T16:51:16.000+03:00
diff --git a/memphis/producer.py b/memphis/producer.py
@@ -170,7 +170,7 @@ async def produce(
                 "$memphis_connectionId": self.connection.connection_id,
             }
 
-            if msg_id is not None:
+            if msg_id is not None and msg_id != "":
                 memphis_headers["msg-id"] = msg_id
 
             if headers is not None:

Original file line number	Diff line number	Diff line change
`@@ -170,7 +170,7 @@ async def produce(`
`170`	`170`	`"$memphis_connectionId": self.connection.connection_id,`
`171`	`171`	`}`
`172`	`172`
`173`		`- if msg_id is not None:`
	`173`	`+ if msg_id is not None and msg_id != "":`
`174`	`174`	`memphis_headers["msg-id"] = msg_id`
`175`	`175`
`176`	`176`	`if headers is not None:`