|
@@ -58,6 +58,7 @@ t_subopts(_) ->
|
|
|
?assertEqual(undefined, emqx_broker:get_subopts(self(), <<"topic">>)),
|
|
?assertEqual(undefined, emqx_broker:get_subopts(self(), <<"topic">>)),
|
|
|
?assertEqual(undefined, emqx_broker:get_subopts(<<"clientid">>, <<"topic">>)),
|
|
?assertEqual(undefined, emqx_broker:get_subopts(<<"clientid">>, <<"topic">>)),
|
|
|
emqx_broker:subscribe(<<"topic">>, <<"clientid">>, #{qos => 1}),
|
|
emqx_broker:subscribe(<<"topic">>, <<"clientid">>, #{qos => 1}),
|
|
|
|
|
+ timer:sleep(200),
|
|
|
?assertEqual(#{qos => 1, subid => <<"clientid">>}, emqx_broker:get_subopts(self(), <<"topic">>)),
|
|
?assertEqual(#{qos => 1, subid => <<"clientid">>}, emqx_broker:get_subopts(self(), <<"topic">>)),
|
|
|
?assertEqual(#{qos => 1, subid => <<"clientid">>}, emqx_broker:get_subopts(<<"clientid">>,<<"topic">>)),
|
|
?assertEqual(#{qos => 1, subid => <<"clientid">>}, emqx_broker:get_subopts(<<"clientid">>,<<"topic">>)),
|
|
|
emqx_broker:subscribe(<<"topic">>, <<"clientid">>, #{qos => 2}),
|
|
emqx_broker:subscribe(<<"topic">>, <<"clientid">>, #{qos => 2}),
|