diff --git a/test/emqx_broker_SUITE.erl b/test/emqx_broker_SUITE.erl index 8cadbf00d..7baa248f3 100644 --- a/test/emqx_broker_SUITE.erl +++ b/test/emqx_broker_SUITE.erl @@ -100,7 +100,7 @@ t_local_subscribe(_) -> timer:sleep(10), ?assertEqual([{self(), undefined}], emqx:subscribers("$local/topic0")), ?assertEqual([{self(), <<"clientId">>}], emqx:subscribers("$local/topic1")), - ?assertEqual([{<<"$local/topic1">>, #{}}, + ?assertEqual([{<<"$local/topic1">>, #{ qos => 0 }}, {<<"$local/topic2">>, #{ qos => 2 }}], emqx:subscriptions({self(), <<"clientId">>})), ?assertEqual(ok, emqx:unsubscribe("$local/topic0")), @@ -117,9 +117,9 @@ t_shared_subscribe(_) -> timer:sleep(10), ct:log("share subscriptions: ~p~n", [emqx:subscriptions({self(), undefined})]), ?assertEqual([{self(), undefined}], emqx:subscribers(<<"$local/$share/group1/topic1">>)), - ?assertEqual([{<<"$local/$share/group1/topic1">>, #{}}, - {<<"$queue/topic3">>, #{}}, - {<<"$share/group2/topic2">>, #{}}], + ?assertEqual([{<<"$local/$share/group1/topic1">>, #{qos => 0}}, + {<<"$queue/topic3">>, #{qos => 0}}, + {<<"$share/group2/topic2">>, #{qos => 0}}], lists:sort(emqx:subscriptions({self(), undefined}))), emqx:unsubscribe("$local/$share/group1/topic1"), emqx:unsubscribe("$share/group2/topic2"),