diff --git a/src/emqx_topic.erl b/src/emqx_topic.erl index 5ea22ea13..eeb04f7c3 100644 --- a/src/emqx_topic.erl +++ b/src/emqx_topic.erl @@ -232,5 +232,7 @@ parse(TopicFilter = <<"$share/", Rest/binary>>, Options) -> _ -> error({invalid_topic_filter, TopicFilter}) end end; +parse(TopicFilter, Options = #{qos := QoS}) -> + {TopicFilter, Options#{rc => QoS}}; parse(TopicFilter, Options) -> {TopicFilter, Options}. \ No newline at end of file