From 3038bd45703daf1aadea9140eb10cacbd013dcac Mon Sep 17 00:00:00 2001
From: Michael Schmidt <michael.k.schmidt@gmail.com>
Date: Thu, 5 Sep 2019 21:09:10 -0500
Subject: [PATCH] Add support for logger per module filtering (#2873)

Add mfa to the meta data to suppor the Erlang Logger's per module / per app filtering
---
 include/logger.hrl  | 2 +-
 src/emqx_tracer.erl | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/include/logger.hrl b/include/logger.hrl
index 6f046e3c2..539371301 100644
--- a/include/logger.hrl
+++ b/include/logger.hrl
@@ -43,6 +43,6 @@
 
 -define(LOG(Level, Format, Args),
         begin
-          (logger:log(Level,#{},#{report_cb => fun(_) -> {'$logger_header'()++(Format), (Args)} end}))
+          (logger:log(Level,#{},#{report_cb => fun(_) -> {'$logger_header'()++(Format), (Args)} end, mfa => {?MODULE, ?FUNCTION_NAME, ?FUNCTION_ARITY}}))
         end).
 
diff --git a/src/emqx_tracer.erl b/src/emqx_tracer.erl
index f9273d3e3..ab102d6bb 100644
--- a/src/emqx_tracer.erl
+++ b/src/emqx_tracer.erl
@@ -65,7 +65,7 @@ trace(publish, #message{topic = <<"$SYS/", _/binary>>}) ->
     ignore;
 trace(publish, #message{from = From, topic = Topic, payload = Payload})
         when is_binary(From); is_atom(From) ->
-    emqx_logger:info(#{topic => Topic}, "PUBLISH to ~s: ~p", [Topic, Payload]).
+    emqx_logger:info(#{topic => Topic, mfa => {?MODULE, ?FUNCTION_NAME, ?FUNCTION_ARITY} }, "PUBLISH to ~s: ~p", [Topic, Payload]).
 
 %% @doc Start to trace client_id or topic.
 -spec(start_trace(trace_who(), logger:level(), string()) -> ok | {error, term()}).