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
commita5e116ca4570207934455163fbe3fac8d53d55d7 (patch)
tree67915626b3d4eb55c351d4dd8b5170f6f9568657
parent62b819d2c304a574f88867336d4de49252c1250a (diff)
downloadrabbitmq-server-a5e116ca4570207934455163fbe3fac8d53d55d7.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 930e48e6..a2a22f8a 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{