summaryrefslogtreecommitdiff
path: root/src/rabbit_trace.erl
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-04-11 13:37:09 +0100
committerSimon MacMullen <simon@rabbitmq.com>2011-04-11 13:37:09 +0100
commit67c8514a974e0773c12c461fad00a72d9a47df0c (patch)
tree415c21e4a61b86b0e444e334a388103e396b7c8f /src/rabbit_trace.erl
parentb80191a7f7df5a3e9888faaaa7272a21507d4370 (diff)
downloadrabbitmq-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.erl40
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.