|
@@ -422,13 +422,13 @@ handle_in(?PACKET(_), Channel = #channel{conn_state = ConnState}) when
|
|
|
ConnState =/= connected andalso ConnState =/= reauthenticating
|
|
ConnState =/= connected andalso ConnState =/= reauthenticating
|
|
|
->
|
|
->
|
|
|
handle_out(disconnect, ?RC_PROTOCOL_ERROR, Channel);
|
|
handle_out(disconnect, ?RC_PROTOCOL_ERROR, Channel);
|
|
|
-handle_in(Packet = ?PUBLISH_PACKET(_QoS), Channel) ->
|
|
|
|
|
|
|
+handle_in(Packet = ?PUBLISH_PACKET(_QoS, Topic, _PacketId), Channel) ->
|
|
|
case emqx_packet:check(Packet) of
|
|
case emqx_packet:check(Packet) of
|
|
|
ok ->
|
|
ok ->
|
|
|
?EXT_TRACE_WITH_PROCESS_FUN(
|
|
?EXT_TRACE_WITH_PROCESS_FUN(
|
|
|
client_publish,
|
|
client_publish,
|
|
|
Packet,
|
|
Packet,
|
|
|
- basic_trace_attrs(Channel),
|
|
|
|
|
|
|
+ (basic_trace_attrs(Channel))#{'message.topic' => Topic},
|
|
|
fun(PacketWithTrace) -> process_publish(PacketWithTrace, Channel) end
|
|
fun(PacketWithTrace) -> process_publish(PacketWithTrace, Channel) end
|
|
|
);
|
|
);
|
|
|
{error, ReasonCode} ->
|
|
{error, ReasonCode} ->
|