diff options
| -rw-r--r-- | deps/rabbit_common/include/rabbit.hrl | 4 | ||||
| -rw-r--r-- | deps/rabbit_common/src/rabbit_writer.erl | 1 |
2 files changed, 5 insertions, 0 deletions
diff --git a/deps/rabbit_common/include/rabbit.hrl b/deps/rabbit_common/include/rabbit.hrl index 1522dca55b..775b59ba0a 100644 --- a/deps/rabbit_common/include/rabbit.hrl +++ b/deps/rabbit_common/include/rabbit.hrl @@ -291,3 +291,7 @@ %% For event audit purposes -define(INTERNAL_USER, <<"rmq-internal">>). -define(UNKNOWN_USER, <<"unknown">>). + +%% Store metadata in the trace files when message tracing is enabled. +-define(LG_INFO(Info), is_pid(whereis(lg)) andalso (lg ! Info)). +-define(LG_PROCESS_TYPE(Type), ?LG_INFO(#{process_type => Type})). diff --git a/deps/rabbit_common/src/rabbit_writer.erl b/deps/rabbit_common/src/rabbit_writer.erl index 66f87c32b3..384d5ecb16 100644 --- a/deps/rabbit_common/src/rabbit_writer.erl +++ b/deps/rabbit_common/src/rabbit_writer.erl @@ -175,6 +175,7 @@ system_code_change(Misc, _Module, _OldVsn, _Extra) -> {ok, Misc}. enter_mainloop(Identity, State) -> + ?LG_PROCESS_TYPE(writer), Deb = sys:debug_options([]), ?store_proc_name(Identity), mainloop(Deb, State). |