For direct client we *do* want the reader pid (amqp_channel) rather than the conn_pid (amqp_direct_connection) here.

1 files changed, 3 insertions, 2 deletions

diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 0f6d251735..603091b1e0 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -250,9 +250,10 @@ handle_call(refresh_config, _From, State = #ch{virtual_host = VHost}) ->
 handle_call(_Request, _From, State) ->
     noreply(State).
 
-handle_cast({method, Method, Content, Flow}, State = #ch{conn_pid = Conn}) ->
+handle_cast({method, Method, Content, Flow},
+            State = #ch{reader_pid = Reader}) ->
     case Flow of
-        flow   -> credit_flow:ack(Conn);
+        flow   -> credit_flow:ack(Reader);
         noflow -> ok
     end,
     try handle_method(Method, Content, State) of