diff --git a/src/emqx_message.erl b/src/emqx_message.erl index b27cc5575..a0ee98434 100644 --- a/src/emqx_message.erl +++ b/src/emqx_message.erl @@ -342,9 +342,14 @@ format(#message{id = Id, flags = Flags, headers = Headers}) -> io_lib:format("Message(Id=~s, QoS=~w, Topic=~s, From=~p, Flags=~s, Headers=~s)", - [emqx_guid:to_hexstr(Id), QoS, Topic, From, format(flags, Flags), + [printable_msg_id(Id), QoS, Topic, From, format(flags, Flags), format(headers, Headers)]). +printable_msg_id(undefined) -> + <<>>; +printable_msg_id(Id) -> + emqx_guid:to_hexstr(Id). + format(flags, Flags) -> io_lib:format("~p", [[Flag || {Flag, true} <- maps:to_list(Flags)]]); format(headers, Headers) ->