diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-04-07 13:12:48 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-04-07 13:12:48 +0100 |
| commit | 66b5fc3789f3a892d373278ecfff531c0c918874 (patch) | |
| tree | 11114da3dca12132fef5f5bcbc6f25cb88adfc4a | |
| parent | fd05e61ba433b0545dd31b0c4e233caad7be200d (diff) | |
| download | rabbitmq-server-git-66b5fc3789f3a892d373278ecfff531c0c918874.tar.gz | |
In a cluster it may be useful to know which node things happened on.
| -rw-r--r-- | src/rabbit_log.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_log.erl b/src/rabbit_log.erl index aa2e990cd7..ba3bd2344a 100644 --- a/src/rabbit_log.erl +++ b/src/rabbit_log.erl @@ -175,7 +175,8 @@ message_to_table(#basic_message{exchange_name = #resource{name = XName}, {<<"app_id">>, longstr, AppId}]), {[{<<"exchange_name">>, longstr, XName}, {<<"routing_key">>, array, [{longstr, K} || K <- RoutingKeys]}, - {<<"headers">>, table, Headers1}], + {<<"headers">>, table, Headers1}, + {<<"node">>, longstr, list_to_binary(atom_to_list(node()))}], list_to_binary(lists:reverse(PFR))}. prune_undefined(Fields) -> |