diff --git a/faststream/_internal/broker/broker.py b/faststream/_internal/broker/broker.py
index 0932ea2327..ee6bd0637e 100644
--- a/faststream/_internal/broker/broker.py
+++ b/faststream/_internal/broker/broker.py
@@ -368,13 +368,13 @@ async def request(
             **kwargs,
         )
 
-        msg: Any = await process_msg(
+        message: Any = await process_msg(
             msg=published_msg,
             middlewares=self._middlewares,
             parser=producer._parser,
             decoder=producer._decoder,
         )
-        return msg
+        return message
 
     @abstractmethod
     async def ping(self, timeout: Optional[float]) -> bool: