From 8ef4df4592b75d20b6682f66011e104d73a24683 Mon Sep 17 00:00:00 2001
From: zhanghongtong <rory-z@outlook.com>
Date: Fri, 16 Apr 2021 21:08:55 +0800
Subject: [PATCH] chore(web hook): fix tests error

---
 .../test/emqx_web_hook_SUITE.erl              | 28 +++++++++++--------
 1 file changed, 16 insertions(+), 12 deletions(-)

diff --git a/apps/emqx_web_hook/test/emqx_web_hook_SUITE.erl b/apps/emqx_web_hook/test/emqx_web_hook_SUITE.erl
index 4d1d3d39a..ca2bbec4d 100644
--- a/apps/emqx_web_hook/test/emqx_web_hook_SUITE.erl
+++ b/apps/emqx_web_hook/test/emqx_web_hook_SUITE.erl
@@ -106,18 +106,22 @@ t_valid(Config) ->
                                , {proto_ver, v5}
                                , {keepalive, 60}
                                ]),
-    {ok, _} = emqtt:connect(C),
-    emqtt:subscribe(C, <<"TopicA">>, qos2),
-    emqtt:publish(C, <<"TopicA">>, <<"Payload...">>, qos2),
-    emqtt:unsubscribe(C, <<"TopicA">>),
-    emqtt:disconnect(C),
-    [begin
-        Maps = emqx_json:decode(P, [return_maps]),
-        validate_hook_resp(Maps),
-        validate_hook_headers(Headers)
-    end
-    || {{P, _Bool}, Headers} <- http_server:get_received_data()],
-    http_server:stop(ServerPid),
+    try 
+        {ok, _} = emqtt:connect(C),
+        emqtt:subscribe(C, <<"TopicA">>, qos2),
+        emqtt:publish(C, <<"TopicA">>, <<"Payload...">>, qos2),
+        emqtt:unsubscribe(C, <<"TopicA">>),
+        emqtt:disconnect(C),
+        timer:sleep(100),
+        [begin
+            Maps = emqx_json:decode(P, [return_maps]),
+            validate_hook_resp(Maps),
+            validate_hook_headers(Headers)
+        end
+    || {{P, _Bool}, Headers} <- http_server:get_received_data()]
+    after
+        http_server:stop(ServerPid)
+    end,
     Config.
 
 t_check_hooked(_) ->