summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-04-12 10:49:30 +0100
committerSimon MacMullen <simon@rabbitmq.com>2011-04-12 10:49:30 +0100
commit3f788007e3e1657fb455ee060af2dce25871f108 (patch)
treea7af84e0df0c39932720dff36ed68c9898afc304
parent024cfcba4f9929da4b25639892ad35c8eca00d2d (diff)
downloadrabbitmq-server-git-3f788007e3e1657fb455ee060af2dce25871f108.tar.gz
Be more specific about what we catch.
-rw-r--r--src/rabbit_trace.erl16
1 files changed, 9 insertions, 7 deletions
diff --git a/src/rabbit_trace.erl b/src/rabbit_trace.erl
index c39a056cc1..1e3553cb2f 100644
--- a/src/rabbit_trace.erl
+++ b/src/rabbit_trace.erl
@@ -68,13 +68,15 @@ tap_trace_out({#resource{name = QName}, _QPid, _QMsgId, Redelivered,
end).
check_trace(XName, VHost, F) ->
- case catch case application:get_env(rabbit, {trace_exchange, VHost}) of
- undefined -> ok;
- {ok, XName} -> ok;
- {ok, TraceExchange} -> F(TraceExchange)
- end of
- {'EXIT', Reason} -> rabbit_log:info("Trace tap died: ~p~n", [Reason]);
- ok -> ok
+ case application:get_env(rabbit, {trace_exchange, VHost}) of
+ undefined -> ok;
+ {ok, XName} -> ok;
+ {ok, TraceX} -> case catch F(TraceX) of
+ {'EXIT', Reason} -> rabbit_log:info(
+ "Trace tap died: ~p~n",
+ [Reason]);
+ ok -> ok
+ end
end.
publish(TraceExchange, VHost, RKPrefix, RKSuffix, Table, Payload) ->