Add qos case

2019-08-06 14:59:59 +08:00 · 2019-08-06 14:59:59 +08:00 · 2c73ab9713
parent 997b693400
commit 2c73ab9713
1 changed files with 2 additions and 0 deletions
--- 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}.