yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor(add-log): log when subscription fails

This commit is contained in:
zhouzb 2020-07-22 10:44:53 +08:00 committed by tigercl
parent 0ee899d0b7
commit 3aa84eeaac
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqx_channel.erl
View File

@ -522,6 +522,10 @@ process_subscribe([], Acc, Channel) ->
process_subscribe([{TopicFilter, SubOpts}|More], Acc, Channel) -> process_subscribe([{TopicFilter, SubOpts}|More], Acc, Channel) ->
{RC, NChannel} = do_subscribe(TopicFilter, SubOpts, Channel), {RC, NChannel} = do_subscribe(TopicFilter, SubOpts, Channel),
case RC > ?RC_GRANTED_QOS_2 of
false -> ok;
true -> ?LOG(warning, "Cannot subscribe ~s due to ~s.", [TopicFilter, emqx_reason_codes:text(RC)])
end,
process_subscribe(More, [RC|Acc], NChannel). process_subscribe(More, [RC|Acc], NChannel).
do_subscribe(TopicFilter, SubOpts = #{qos := QoS}, Channel = do_subscribe(TopicFilter, SubOpts = #{qos := QoS}, Channel =