root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

MQTT print stacktrace/payload only at debug level

This commit is contained in:
Chunyi Lyu 2023-01-31 10:36:08 +00:00
parent b02c268632
commit 6205e5e5e3
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/rabbitmq_mqtt/src/rabbit_mqtt_reader.erl vendored
View File

@ -365,7 +365,8 @@ process_received_bytes(Bytes,
{stop, normal, {_SendWill = false, pstate(State, ProcState1)}}
end;
{error, {cannot_parse, Reason, Stacktrace}} ->
?LOG_ERROR("MQTT cannot parse a packet on connection '~ts', reason: ~tp, "
?LOG_ERROR("Unparseable MQTT packet received from connection ~ts", [ConnName]),
?LOG_DEBUG("MQTT cannot parse a packet on connection '~ts', reason: ~tp, "
"stacktrace: ~tp, payload (first 100 bytes): ~tp",
[ConnName, Reason, Stacktrace, rabbit_mqtt_util:truncate_binary(Bytes, 100)]),
{stop, {shutdown, Reason}, State};

2
deps/rabbitmq_web_mqtt/src/rabbit_web_mqtt_handler.erl vendored
View File

@ -286,7 +286,7 @@ parse(Data, ParseState) ->
rabbit_mqtt_packet:parse(Data, ParseState)
catch
_:Reason:Stacktrace ->
?LOG_ERROR("Web MQTT cannot parse a packet, reason: ~tp, stacktrace: ~tp, "
?LOG_DEBUG("Web MQTT cannot parse a packet, reason: ~tp, stacktrace: ~tp, "
"payload (first 100 bytes): ~tp",
[Reason, Stacktrace, rabbit_mqtt_util:truncate_binary(Data, 100)]),
{error, cannot_parse}