Skip to content

Commit d1936df

Browse files
lukebakkenmergify-bot
authored andcommitted
Add basic filter for "Discarding message..." messages
Fixes #4557 (cherry picked from commit 9ba3cff) (cherry picked from commit 9091f85)
1 parent 6b08300 commit d1936df

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

deps/rabbit/apps/rabbitmq_prelaunch/src/rabbit_prelaunch_early_logging.erl

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,18 @@ add_rmqlog_filter(LogLevels) ->
7070
add_erlang_specific_filters(_) ->
7171
_ = logger:add_handler_filter(
7272
default, progress_reports, {fun logger_filters:progress/2, stop}),
73+
MsgFilter = fun(#{level := error, meta := #{error_logger := #{emulator := true, tag := error}}, msg := {"~s~n", Msg}}, _FilterArg) ->
74+
case string:find(Msg, "Discarding message ") of
75+
nomatch ->
76+
ignore;
77+
_ ->
78+
stop
79+
end;
80+
(_LogEvent, _FilterArg) ->
81+
ignore
82+
end,
83+
_ = logger:add_handler_filter(
84+
default, discarded_messages, {MsgFilter, undefined}),
7385
ok.
7486

7587
filter_log_event(

0 commit comments

Comments
 (0)