diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-11-28 15:29:29 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-11-28 15:29:29 +0000 |
| commit | 2ad1cc60082bc47b562dd72eec45e7b6869ce0da (patch) | |
| tree | 3b309b7164f6c7ce3dbe6ae2c4737501f54ffa1f | |
| parent | 013608177ac3cddcecb3d204239ceb70b6bae4c7 (diff) | |
| download | rabbitmq-server-git-2ad1cc60082bc47b562dd72eec45e7b6869ce0da.tar.gz | |
fix tuple arity mismatch
I strongly dislike dynamically-typed languages.
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 3d1464bc2d..a60dc19914 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -778,13 +778,13 @@ monitor_queue(QPid, State = #q{queue_monitors = QMons}) -> handle_queue_down(QPid, State = #q{queue_monitors = QMons, unconfirmed = UC}) -> case dict:find(QPid, QMons) of - error -> + error -> noreply(State); {ok, _} -> #resource{name = QName} = qname(State), rabbit_log:info("DLQ ~p (for ~p) died~n", [QPid, QName]), MsgSeqNos = [MsgSeqNo || - {MsgSeqNo, {QPids, _, _}} <- gb_trees:to_list(UC), + {MsgSeqNo, {QPids, _}} <- gb_trees:to_list(UC), gb_sets:is_member(QPid, QPids)], handle_confirm(MsgSeqNos, QPid, State#q{queue_monitors = dict:erase(QPid, QMons)}) |