summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2011-01-13 01:22:57 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2011-01-13 01:22:57 +0000
commit92a62a0310d74765ca3b36077ebf3fa5c7c2496b (patch)
tree67915626b3d4eb55c351d4dd8b5170f6f9568657
parent027a7d46a1d0c02181be3dd326c5764df30d437f (diff)
downloadrabbitmq-server-git-92a62a0310d74765ca3b36077ebf3fa5c7c2496b.tar.gz
tiny refactor: use dict:fetch instead of dict:find
-rw-r--r--src/rabbit_channel.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 930e48e6cd..a2a22f8a07 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -489,8 +489,8 @@ confirm(MsgSeqNos, QPid, State) ->
queues_for_msg = QFM0}}) ->
case gb_sets:is_element(MsgSeqNo, UC0) of
false -> {DMs, State0};
- true -> {ok, Qs} = dict:find(MsgSeqNo, QFM0),
- Qs1 = sets:del_element(QPid, Qs),
+ true -> Qs1 = sets:del_element(
+ QPid, dict:fetch(MsgSeqNo, QFM0)),
case sets:size(Qs1) of
0 -> {[MsgSeqNo | DMs],
State0#ch{