diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2016-02-04 03:06:32 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2016-02-04 03:06:32 +0300 |
| commit | feab45a50294b7aee8e39c0c28ce41e875b58455 (patch) | |
| tree | 34d1f76683dea8df7f4b7904f9fbd460e301c8c5 /src | |
| parent | c273270f61a0a78069cacf9443e64a32eb4b4dcc (diff) | |
| parent | f9adbe0beb355f40194c7cc6b548b6c1f40228c5 (diff) | |
| download | rabbitmq-server-git-feab45a50294b7aee8e39c0c28ce41e875b58455.tar.gz | |
Merge branch 'stable'
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_error_logger.erl | 4 |
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. |