diff options
| author | Michael Klishin <michael@rabbitmq.com> | 2014-06-17 08:12:13 +0400 |
|---|---|---|
| committer | Michael Klishin <michael@rabbitmq.com> | 2014-06-17 08:12:13 +0400 |
| commit | 94bc8593108dc28ce1c620bbf238f54cf2227a80 (patch) | |
| tree | eace209ee4f91eb2440703a48a4e935ff62074e1 /src | |
| parent | de12430efcda4a49ccb2d5577061a2a72576bc88 (diff) | |
| download | rabbitmq-server-git-94bc8593108dc28ce1c620bbf238f54cf2227a80.tar.gz | |
Include vhost into trace message headers
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_trace.erl | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/rabbit_trace.erl b/src/rabbit_trace.erl index aafd81df9c..017d1ab242 100644 --- a/src/rabbit_trace.erl +++ b/src/rabbit_trace.erl @@ -55,14 +55,17 @@ enabled(VHost) -> lists:member(VHost, VHosts). tap_in(_Msg, none) -> ok; -tap_in(Msg = #basic_message{exchange_name = #resource{name = XName}}, TraceX) -> - trace(TraceX, Msg, <<"publish">>, XName, []). +tap_in(Msg = #basic_message{exchange_name = #resource{name = XName, + virtual_host = VHost}}, TraceX) -> + trace(TraceX, Msg, <<"publish">>, XName, + [{<<"vhost">>, longstr, VHost}]). tap_out(_Msg, none) -> ok; -tap_out({#resource{name = QName}, _QPid, _QMsgId, Redelivered, Msg}, TraceX) -> +tap_out({#resource{name = QName, virtual_host = VHost}, _QPid, _QMsgId, Redelivered, Msg}, TraceX) -> RedeliveredNum = case Redelivered of true -> 1; false -> 0 end, trace(TraceX, Msg, <<"deliver">>, QName, - [{<<"redelivered">>, signedint, RedeliveredNum}]). + [{<<"redelivered">>, signedint, RedeliveredNum}, + {<<"vhost">>, longstr, VHost}]). %%---------------------------------------------------------------------------- |