diff --git a/src/emqx_session.erl b/src/emqx_session.erl index 04cae7f4f..276454cd9 100644 --- a/src/emqx_session.erl +++ b/src/emqx_session.erl @@ -1027,7 +1027,6 @@ drain_q(Cnt, Msgs, Q) -> case emqx_mqueue:out(Q) of {empty, _Q} -> {Msgs, Q}; {{value, Msg}, Q1} -> - io:format("Drain Msg: ~p~n", [Msg]), drain_q(Cnt-1, [Msg|Msgs], Q1) end.