From c2d49ff34fd5dedb754967807234bd883363cfda Mon Sep 17 00:00:00 2001 From: Ivan Dyachkov Date: Thu, 18 Jul 2024 08:34:00 +0200 Subject: [PATCH] chore(rmq_tests): fix rabbitmq tests Co-authored-by: Ilya Averyanov --- .../test/emqx_bridge_rabbitmq_v2_SUITE.erl | 25 ++++++++----------- 1 file changed, 10 insertions(+), 15 deletions(-) diff --git a/apps/emqx_bridge_rabbitmq/test/emqx_bridge_rabbitmq_v2_SUITE.erl b/apps/emqx_bridge_rabbitmq/test/emqx_bridge_rabbitmq_v2_SUITE.erl index 96a6fa13d..463a882d2 100644 --- a/apps/emqx_bridge_rabbitmq/test/emqx_bridge_rabbitmq_v2_SUITE.erl +++ b/apps/emqx_bridge_rabbitmq/test/emqx_bridge_rabbitmq_v2_SUITE.erl @@ -321,23 +321,18 @@ t_action_not_exist_exchange(_Config) -> Trace = snabbkaffe:collect_trace(50), ?assert( lists:any( - fun(K) -> - maps:get(msg, K, not_found) =:= - emqx_bridge_rabbitmq_connector_rabbit_publish_failed_with_msg + fun + (#{msg := emqx_bridge_rabbitmq_connector_rabbit_publish_failed_with_msg}) -> + true; + (#{msg := emqx_bridge_rabbitmq_connector_rabbit_publish_failed_con_not_ready}) -> + true; + (_) -> + false end, Trace - ) - ), - ?assert( - lists:any( - fun(K) -> - maps:get(msg, K, not_found) =:= - emqx_bridge_rabbitmq_connector_rabbit_publish_failed_con_not_ready - end, - Trace - ) - ), - ok. + ), + Trace + ). t_replace_action_source(Config) -> Action = #{<<"rabbitmq">> => #{<<"my_action">> => rabbitmq_action()}},