|
|
@@ -550,6 +550,7 @@ handle_msg(
|
|
|
},
|
|
|
handle_incoming(Packet, NState);
|
|
|
handle_msg({incoming, Packet}, State) ->
|
|
|
+ ?TRACE("MQTT", "mqtt_packet_received", #{packet => Packet}),
|
|
|
handle_incoming(Packet, State);
|
|
|
handle_msg({outgoing, Packets}, State) ->
|
|
|
handle_outgoing(Packets, State);
|
|
|
@@ -783,7 +784,6 @@ parse_incoming(Data, Packets, State = #state{parse_state = ParseState}) ->
|
|
|
|
|
|
handle_incoming(Packet, State) when is_record(Packet, mqtt_packet) ->
|
|
|
ok = inc_incoming_stats(Packet),
|
|
|
- ?TRACE("MQTT", "mqtt_packet_received", #{packet => Packet}),
|
|
|
with_channel(handle_in, [Packet], State);
|
|
|
handle_incoming(FrameError, State) ->
|
|
|
with_channel(handle_in, [FrameError], State).
|