diff --git a/src/emqx_packet.erl b/src/emqx_packet.erl index 1d1e29c6a..1db586cea 100644 --- a/src/emqx_packet.erl +++ b/src/emqx_packet.erl @@ -55,6 +55,8 @@ validate(?UNSUBSCRIBE_PACKET(PacketId, TopicFilters)) -> validate_packet_id(PacketId) andalso ok == lists:foreach(fun emqx_topic:validate/1, TopicFilters); +validate(?PUBLISH_PACKET(_QoS, <<>>, _, #{'Topic-Alias':= _I}, _)) -> + true; validate(?PUBLISH_PACKET(_QoS, <<>>, _, _, _)) -> error(topic_name_invalid); validate(?PUBLISH_PACKET(_QoS, Topic, _, Properties, _)) ->