From 2c73ab9713d704a2b6f038fdc05cab98fd843b96 Mon Sep 17 00:00:00 2001 From: turtled Date: Tue, 6 Aug 2019 14:59:59 +0800 Subject: [PATCH] Add qos case --- src/emqx_topic.erl | 2 ++ 1 file changed, 2 insertions(+) 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