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 | f280daebf105d43752ff3a1f524c4d39db67c980 (patch) | |
| tree | e161d651544678c41c5ed355d88a8da69fa26df7 /src | |
| parent | 6f2e0baadf31ceb6ad37bef0fab2102acb51675a (diff) | |
| download | rabbitmq-server-git-f280daebf105d43752ff3a1f524c4d39db67c980.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
Diffstat (limited to 'src')
| -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 c78edcfa33..6e88f259f0 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), |