diff options
| author | Michael Klishin <michael@novemberain.com> | 2016-02-04 03:06:05 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@novemberain.com> | 2016-02-04 03:06:05 +0300 |
| commit | f9adbe0beb355f40194c7cc6b548b6c1f40228c5 (patch) | |
| tree | 05f4c1302cbef8c8d90e5c71cdbb7d753b7bc2df /src | |
| parent | ddd93166663e574a96f04208dd27098db35b733f (diff) | |
| parent | b8b24048ec5eb35cfe87e1ea1d95bc518f66214e (diff) | |
| download | rabbitmq-server-git-f9adbe0beb355f40194c7cc6b548b6c1f40228c5.tar.gz | |
Merge pull request #604 from rabbitmq/rabbitmq-server-595
Add emitting node info to amq.rabbitmq.log messages
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 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. |