summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-12-20 13:00:01 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2010-12-20 13:00:01 +0000
commit7743428ea01da0db13220981aa9b1021920ece07 (patch)
tree62601201df5f913e3213e37f20b2816285d67a2d
parent072cf84920072b28a62dc5f90eec156e957a036d (diff)
downloadrabbitmq-server-7743428ea01da0db13220981aa9b1021920ece07.tar.gz
cosmetic
-rw-r--r--src/rabbit_amqqueue.erl10
1 files changed, 4 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index 71fd7a17..e3e89211 100644
--- a/src/rabbit_amqqueue.erl
+++ b/src/rabbit_amqqueue.erl
@@ -503,15 +503,13 @@ pseudo_queue(QueueName, Pid) ->
pid = Pid}.
safe_delegate_call_ok(F, Pids) ->
- {_, Bad} = delegate:invoke(Pids,
- fun (Pid) ->
+ case delegate:invoke(Pids, fun (Pid) ->
rabbit_misc:with_exit_handler(
fun () -> ok end,
fun () -> F(Pid) end)
- end),
- case Bad of
- [] -> ok;
- _ -> {error, Bad}
+ end) of
+ {_, []} -> ok;
+ {_, Bad} -> {error, Bad}
end.
delegate_call(Pid, Msg, Timeout) ->