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
commita1b63d6cbe42bbc8da8c23b0dff32d7e69bb3db8 (patch)
tree62601201df5f913e3213e37f20b2816285d67a2d
parentead11ac25842d35b010207e802d284136b0895f9 (diff)
downloadrabbitmq-server-git-a1b63d6cbe42bbc8da8c23b0dff32d7e69bb3db8.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 71fd7a17db..e3e89211b5 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) ->