fix: KeyError 'reply_to' in rabbit (#1999)

airtai · Dec 19, 2024 · 5f9c7b6 · 5f9c7b6
1 parent a728ba7
commit 5f9c7b6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/faststream/rabbit/publisher/usecase.py b/faststream/rabbit/publisher/usecase.py
@@ -72,7 +72,7 @@ def __init__(
 
         request_options = dict(message_kwargs)
         self.headers = request_options.pop("headers") or {}
-        self.reply_to = request_options.pop("reply_to", "")
+        self.reply_to = request_options.pop("reply_to", None) or ""
         self.timeout = request_options.pop("timeout", None)
 
         message_options, _ = filter_by_dict(MessageOptions, request_options)

diff --git a/faststream/rabbit/response.py b/faststream/rabbit/response.py
@@ -75,7 +75,7 @@ def __init__(
         **message_options: Unpack["MessageOptions"],
     ) -> None:
         headers = message_options.pop("headers", {})
-        reply_to = message_options.pop("reply_to") or ""
+        reply_to = message_options.pop("reply_to", None) or ""
         correlation_id = message_options.pop("correlation_id", None)
 
         super().__init__(