diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2011-04-11 13:37:09 +0100 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2011-04-11 13:37:09 +0100 |
commit | 67c8514a974e0773c12c461fad00a72d9a47df0c (patch) | |
tree | 415c21e4a61b86b0e444e334a388103e396b7c8f /src/rabbit_trace.erl | |
parent | b80191a7f7df5a3e9888faaaa7272a21507d4370 (diff) | |
download | rabbitmq-server-67c8514a974e0773c12c461fad00a72d9a47df0c.tar.gz |
Get rid of that "Bin" suffix, it was inconsistent and strings are generally binaries in the broker anyway.
Diffstat (limited to 'src/rabbit_trace.erl')
-rw-r--r-- | src/rabbit_trace.erl | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/src/rabbit_trace.erl b/src/rabbit_trace.erl index eb25121b..a823879a 100644 --- a/src/rabbit_trace.erl +++ b/src/rabbit_trace.erl @@ -36,26 +36,26 @@ %%---------------------------------------------------------------------------- tap_trace_in(Message = #basic_message{ - exchange_name = #resource{virtual_host = VHostBin, - name = XNameBin}}, User) -> + exchange_name = #resource{virtual_host = VHost, + name = XName}}, User) -> check_trace( - XNameBin, - VHostBin, - fun (TraceExchangeBin) -> + XName, + VHost, + fun (TraceExchange) -> {EncodedMetadata, Payload} = message_to_table(Message, User), - publish(TraceExchangeBin, VHostBin, <<"publish">>, XNameBin, + publish(TraceExchange, VHost, <<"publish">>, XName, EncodedMetadata, Payload) end). -tap_trace_out({#resource{name = QNameBin}, _QPid, _QMsgId, Redelivered, +tap_trace_out({#resource{name = QName}, _QPid, _QMsgId, Redelivered, Message = #basic_message{ - exchange_name = #resource{virtual_host = VHostBin, - name = XNameBin}}}, + exchange_name = #resource{virtual_host = VHost, + name = XName}}}, ConsumerTagOrNone, User) -> check_trace( - XNameBin, - VHostBin, - fun (TraceExchangeBin) -> + XName, + VHost, + fun (TraceExchange) -> RedeliveredNum = case Redelivered of true -> 1; false -> 0 end, {EncodedMetadata, Payload} = message_to_table(Message, User), Fields0 = [{<<"redelivered">>, signedint, RedeliveredNum}] @@ -65,22 +65,22 @@ tap_trace_out({#resource{name = QNameBin}, _QPid, _QMsgId, Redelivered, CTag -> [{<<"consumer_tag">>, longstr, CTag} | Fields0] end, - publish(TraceExchangeBin, VHostBin, <<"deliver">>, QNameBin, + publish(TraceExchange, VHost, <<"deliver">>, QName, Fields, Payload) end). -check_trace(XNameBin, VHostBin, F) -> - case catch case application:get_env(rabbit, {trace_exchange, VHostBin}) of - undefined -> ok; - {ok, XNameBin} -> ok; - {ok, TraceExchangeBin} -> F(TraceExchangeBin) +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 end. -publish(TraceExchangeBin, VHostBin, RKPrefix, RKSuffix, Table, Payload) -> - rabbit_basic:publish(rabbit_misc:r(VHostBin, exchange, TraceExchangeBin), +publish(TraceExchange, VHost, RKPrefix, RKSuffix, Table, Payload) -> + rabbit_basic:publish(rabbit_misc:r(VHost, exchange, TraceExchange), <<RKPrefix/binary, ".", RKSuffix/binary>>, #'P_basic'{headers = Table}, Payload), ok. |