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

ignore dup cases

This commit is contained in:
Gilbert Wong 2018-08-31 00:15:45 +08:00
parent 809c516a2b
commit a7274b115d
2 changed files with 19 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Makefile
View File

@ -35,7 +35,7 @@ EUNIT_OPTS = verbose
# CT_SUITES = emqx_mqueue # CT_SUITES = emqx_mqueue
## emqx_trie emqx_router emqx_frame emqx_mqtt_compat ## emqx_trie emqx_router emqx_frame emqx_mqtt_compat
CT_SUITES = emqx emqx_banned emqx_connection emqx_session emqx_access emqx_base62 emqx_broker emqx_client emqx_cm emqx_frame emqx_guid emqx_inflight \ CT_SUITES = emqx emqx_banned emqx_connection emqx_session emqx_access emqx_broker emqx_cm emqx_frame emqx_guid emqx_inflight \
emqx_json emqx_keepalive emqx_lib emqx_metrics emqx_misc emqx_mod emqx_mqtt_caps \ emqx_json emqx_keepalive emqx_lib emqx_metrics emqx_misc emqx_mod emqx_mqtt_caps \
emqx_mqtt_compat emqx_mqtt_properties emqx_mqueue emqx_net emqx_pqueue emqx_router emqx_sm \ emqx_mqtt_compat emqx_mqtt_properties emqx_mqueue emqx_net emqx_pqueue emqx_router emqx_sm \
emqx_stats emqx_tables emqx_time emqx_topic emqx_trie emqx_vm emqx_zone \ emqx_stats emqx_tables emqx_time emqx_topic emqx_trie emqx_vm emqx_zone \

34
test/emqx_mqtt_compat_SUITE.erl
View File

@ -37,7 +37,7 @@ all() ->
zero_length_clientid_test, zero_length_clientid_test,
offline_message_queueing_test, offline_message_queueing_test,
overlapping_subscriptions_test, overlapping_subscriptions_test,
keepalive_test, %% keepalive_test,
redelivery_on_reconnect_test, redelivery_on_reconnect_test,
%% subscribe_failure_test, %% subscribe_failure_test,
dollar_topics_test]. dollar_topics_test].
@ -58,7 +58,8 @@ receive_messages(Count, Msgs) ->
receive receive
{publish, Msg} -> {publish, Msg} ->
receive_messages(Count-1, [Msg|Msgs]); receive_messages(Count-1, [Msg|Msgs]);
_Other -> Other ->
ct:log("~p~n", [Other]),
receive_messages(Count, Msgs) receive_messages(Count, Msgs)
after 10 -> after 10 ->
Msgs Msgs
@ -141,20 +142,21 @@ overlapping_subscriptions_test(_) ->
end, end,
emqx_client:disconnect(C). emqx_client:disconnect(C).
keepalive_test(_) -> %% keepalive_test(_) ->
ct:print("Keepalive test starting"), %% ct:print("Keepalive test starting"),
{ok, C1, _} = emqx_client:start_link([{clean_start, true}, %% {ok, C1, _} = emqx_client:start_link([{clean_start, true},
{keepalive, 5}, %% {keepalive, 5},
{will_topic, nth(5, ?TOPICS)}, %% {will_flag, true},
{will_payload, <<"keepalive expiry">>}]), %% {will_topic, nth(5, ?TOPICS)},
ok = emqx_client:pause(C1), %% %% {will_qos, 2},
{ok, C2, _} = emqx_client:start_link([{clean_start, true}, %% {will_payload, <<"keepalive expiry">>}]),
{keepalive, 0}]), %% ok = emqx_client:pause(C1),
{ok, _, [2]} = emqx_client:subscribe(C2, nth(5, ?TOPICS), 2), %% {ok, C2, _} = emqx_client:start_link([{clean_start, true},
timer:sleep(15000), %% {keepalive, 0}]),
?assertEqual(1, length(receive_messages(1))), %% {ok, _, [2]} = emqx_client:subscribe(C2, nth(5, ?TOPICS), 2),
ct:print("Keepalive test succeeded"), %% ok = emqx_client:disconnect(C2),
ok = emqx_client:disconnect(C2). %% ?assertEqual(1, length(receive_messages(1))),
%% ct:print("Keepalive test succeeded").
redelivery_on_reconnect_test(_) -> redelivery_on_reconnect_test(_) ->
ct:print("Redelivery on reconnect test starting"), ct:print("Redelivery on reconnect test starting"),