diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2011-05-19 18:40:35 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-05-19 18:40:35 +0100 |
commit | b52f2ffca60521f21f4dc74d3ec0dccc754e6764 (patch) | |
tree | bb55330d609b72593c79d4437d58c4d27fa62cd4 | |
parent | 358a68480d6eb0b0c388deb166342d49c56382f3 (diff) | |
download | rabbitmq-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.erl | 13 |
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 |