summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2011-05-19 18:40:35 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2011-05-19 18:40:35 +0100
commitb52f2ffca60521f21f4dc74d3ec0dccc754e6764 (patch)
treebb55330d609b72593c79d4437d58c4d27fa62cd4
parent358a68480d6eb0b0c388deb166342d49c56382f3 (diff)
downloadrabbitmq-server-b52f2ffca60521f21f4dc74d3ec0dccc754e6764.tar.gz
sometimes clarity trumps performance
I can't actually detect a difference in performance here, though I'm sure the new code is slower than the old one.
-rw-r--r--src/rabbit_trace.erl13
1 files changed, 4 insertions, 9 deletions
diff --git a/src/rabbit_trace.erl b/src/rabbit_trace.erl
index df44ed25..36125376 100644
--- a/src/rabbit_trace.erl
+++ b/src/rabbit_trace.erl
@@ -39,29 +39,24 @@ init(VHost) ->
trace_exchange(VHost).
tap_trace_in(Msg, TraceX) ->
- maybe_trace(Msg, TraceX, publish, []).
+ maybe_trace(Msg, TraceX, <<"publish">>, xname(Msg), []).
tap_trace_out({#resource{name = QName}, _QPid, _QMsgId, Redelivered, Msg},
TraceX) ->
RedeliveredNum = case Redelivered of true -> 1; false -> 0 end,
- maybe_trace(Msg, TraceX, {deliver, QName},
+ maybe_trace(Msg, TraceX, <<"deliver">>, QName,
[{<<"redelivered">>, signedint, RedeliveredNum}]).
xname(#basic_message{exchange_name = #resource{name = XName}}) -> XName.
vhost(#basic_message{exchange_name = #resource{virtual_host = VHost}}) -> VHost.
-maybe_trace(_Msg, none, _Mode, _Extra) ->
+maybe_trace(_Msg, none, _RKPrefix, _RKSuffix, _Extra) ->
ok;
-maybe_trace(Msg0, TraceX, Mode, Extra) ->
+maybe_trace(Msg0, TraceX, RKPrefix, RKSuffix, Extra) ->
case xname(Msg0) of
TraceX -> ok;
_ -> Msg = ensure_content_decoded(Msg0),
X = rabbit_misc:r(vhost(Msg), exchange, TraceX),
- {RKPrefix, RKSuffix} =
- case Mode of
- publish -> {<<"publish">>, xname(Msg0)};
- {deliver, Q} -> {<<"deliver">>, Q}
- end,
RKey = <<RKPrefix/binary, ".", RKSuffix/binary>>,
P = #'P_basic'{headers = msg_to_table(Msg) ++ Extra},
case catch rabbit_basic:publish(X, RKey, P, payload(Msg)) of