diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-01-11 14:19:06 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-01-11 14:19:06 +0000 |
| commit | cb128caca1ef49d28f72e76d8c10ef458ce8c485 (patch) | |
| tree | 5d381561d1a513af71656d6e71b1efbbe294a95a | |
| parent | cfa7edee2441ba753a9e255a21de96d8287730b3 (diff) | |
| download | rabbitmq-server-cb128caca1ef49d28f72e76d8c10ef458ce8c485.tar.gz | |
Actually we should use conn_pid here since that goes to the same place for network connections and a more reasonable place for direct ones.
| -rw-r--r-- | src/rabbit_channel.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 4222a0e7..c95aaad7 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -244,8 +244,8 @@ handle_call(refresh_config, _From, State = #ch{virtual_host = VHost}) -> handle_call(_Request, _From, State) -> noreply(State). -handle_cast({method, Method, Content}, State = #ch{reader_pid = Reader}) -> - rabbit_flow:ack(Reader), +handle_cast({method, Method, Content}, State = #ch{conn_pid = Conn}) -> + rabbit_flow:ack(Conn), try handle_method(Method, Content, State) of {reply, Reply, NewState} -> ok = rabbit_writer:send_command(NewState#ch.writer_pid, Reply), |