call/2 -> call/3.

1 files changed, 2 insertions, 1 deletions

diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 9da6ac448c..418653dfb0 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -164,9 +164,10 @@ declare_fast_reply_to(<<"amq.rabbitmq.reply-to">>) ->
 declare_fast_reply_to(<<"amq.rabbitmq.reply-to.", Rest/binary>>) ->
     case decode_fast_reply_to(Rest) of
         {ok, Pid, Key} ->
+            Msg = {declare_fast_reply_to, Key},
             rabbit_misc:with_exit_handler(
               rabbit_misc:const(not_found),
-              fun() -> gen_server2:call(Pid, {declare_fast_reply_to, Key}) end);
+              fun() -> gen_server2:call(Pid, Msg, infinity) end);
         error ->
             not_found
     end;