diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2016-02-04 02:27:09 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2016-02-04 02:27:09 +0300 |
| commit | b8b24048ec5eb35cfe87e1ea1d95bc518f66214e (patch) | |
| tree | 05f4c1302cbef8c8d90e5c71cdbb7d753b7bc2df | |
| parent | ddd93166663e574a96f04208dd27098db35b733f (diff) | |
| download | rabbitmq-server-git-b8b24048ec5eb35cfe87e1ea1d95bc518f66214e.tar.gz | |
Add emitting node info to amq.rabbitmq.log messages
Fixes #595.
| -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 bbaf9577f9..d847284243 100644 --- a/src/rabbit_error_logger.erl +++ b/src/rabbit_error_logger.erl @@ -104,9 +104,11 @@ 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. |