diff --git a/src/emqx_protocol.erl b/src/emqx_protocol.erl index 364cc0ec1..39929513e 100644 --- a/src/emqx_protocol.erl +++ b/src/emqx_protocol.erl @@ -364,7 +364,9 @@ process_packet(?SUBSCRIBE_PACKET(PacketId, Properties, RawTopicFilters), case IsBridge of true -> [{RawTopic, SubOpts#{rap => 1}} || {RawTopic, SubOpts} <- RawTopicFilters]; false -> [{RawTopic, SubOpts#{rap => 0}} || {RawTopic, SubOpts} <- RawTopicFilters] - end + end; + true -> + RawTopicFilters end, case check_subscribe( parse_topic_filters(?SUBSCRIBE, RawTopicFilters1), PState) of