From 1d5fe14a307d3c5af5ca35020f882036cbbe843b Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Wed, 1 Mar 2023 16:16:49 -0300 Subject: [PATCH] test: remove sleeps --- .../test/emqx_bridge_impl_kafka_producer_SUITE.erl | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl b/lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl index b1375e150..7a214de08 100644 --- a/lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl +++ b/lib-ee/emqx_ee_bridge/test/emqx_bridge_impl_kafka_producer_SUITE.erl @@ -417,9 +417,7 @@ t_failed_creation_then_fix(Config) -> ), ValidConfigAtom = ValidConfigAtom1#{bridge_name => Name}, {ok, State} = ?PRODUCER:on_start(ResourceId, ValidConfigAtom), - %% To make sure we get unique value - timer:sleep(1), - Time = erlang:monotonic_time(), + Time = erlang:unique_integer(), BinTime = integer_to_binary(Time), Msg = #{ clientid => BinTime, @@ -530,9 +528,7 @@ publish_helper( {ok, _} = emqx_bridge:create( <<"kafka_producer">>, list_to_binary(Name), Conf ), - %% To make sure we get unique value - timer:sleep(1), - Time = erlang:monotonic_time(), + Time = erlang:unique_integer(), BinTime = integer_to_binary(Time), Partition = 0, Msg = #{