diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-10-26 13:02:38 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-10-26 13:02:38 +0000 |
| commit | 164a6676f55acb4b654dce2258c7f23ea71d8ba9 (patch) | |
| tree | e161d651544678c41c5ed355d88a8da69fa26df7 | |
| parent | 3ed2a437a10a7ecd4b1e476180d8872bc0783e52 (diff) | |
| download | rabbitmq-server-164a6676f55acb4b654dce2258c7f23ea71d8ba9.tar.gz | |
bug 21758. Missed the first case in handle_ch_down which was noreply(... and needed turning into {ok, State} in order to match the other cases
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index c78edcfa..6e88f259 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -297,7 +297,7 @@ should_auto_delete(State) -> is_unused(State). handle_ch_down(DownPid, State = #q{exclusive_consumer = Holder}) -> case lookup_ch(DownPid) of - not_found -> noreply(State); + not_found -> {ok, State}; #cr{monitor_ref = MonitorRef, ch_pid = ChPid, txn = Txn, unacked_messages = UAM} -> erlang:demonitor(MonitorRef), |