diff options
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. |