diff --git a/faststream/rabbit/publisher/usecase.py b/faststream/rabbit/publisher/usecase.py
index abb48bb1b1..d4b736cfa4 100644
--- 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
index f45cbb07ce..ffb1ad3b31 100644
--- 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__(