We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 120c454 commit ebad1baCopy full SHA for ebad1ba
src/zmqtt/client.py
@@ -561,7 +561,10 @@ async def request(
561
else:
562
reply_topic = f"_zmqtt/reply/{os.urandom(16).hex()}"
563
564
- corr = (properties.correlation_data if properties is not None else None) or os.urandom(16)
+ if properties is not None and properties.correlation_data is not None:
565
+ corr = properties.correlation_data
566
+ else:
567
+ corr = os.urandom(16)
568
569
if properties is not None:
570
req_props = dataclasses.replace(
0 commit comments