diff options
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
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 |