summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorDaniil Fedotov <dfedotov@pivotal.io>2016-02-04 18:58:30 +0000
committerDaniil Fedotov <dfedotov@pivotal.io>2016-02-04 18:58:30 +0000
commit0d5a1f2868acff46746545f3a1020faa868c0e63 (patch)
tree825df3e890ca35c2b6e67c6b18e8468a50b521af /src
parentf608e304e0dbeb11154514eb249848e482e1d52f (diff)
parentfeab45a50294b7aee8e39c0c28ce41e875b58455 (diff)
downloadrabbitmq-server-git-0d5a1f2868acff46746545f3a1020faa868c0e63.tar.gz
Merge branch 'master' into rabbitmq-server-590
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_error_logger.erl4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_error_logger.erl b/src/rabbit_error_logger.erl
index e8b7ce5669..efe8495299 100644
--- a/src/rabbit_error_logger.erl
+++ b/src/rabbit_error_logger.erl
@@ -103,10 +103,12 @@ publish1(RoutingKey, Format, Data, LogExch) ->
Timestamp = time_compat:os_system_time(seconds),
Args = [truncate:term(A, ?LOG_TRUNC) || A <- Data],
+ Headers = [{<<"node">>, longstr, list_to_binary(atom_to_list(node()))}],
{ok, _DeliveredQPids} =
rabbit_basic:publish(LogExch, RoutingKey,
#'P_basic'{content_type = <<"text/plain">>,
- timestamp = Timestamp},
+ timestamp = Timestamp,
+ headers = Headers},
list_to_binary(io_lib:format(Format, Args))),
ok.