diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2020-10-30 15:48:49 -0700 |
|---|---|---|
| committer | Luke Bakken <lbakken@pivotal.io> | 2020-10-30 15:48:49 -0700 |
| commit | dfd658343ca1d705ca88cf0034f56520f92ed434 (patch) | |
| tree | 16983b48f26fe073d1d558743c1da5cb8dede3b9 | |
| parent | 74ca4e0365ac32b43d99c29cc19e568d6a9c207d (diff) | |
| download | rabbitmq-server-git-dfd658343ca1d705ca88cf0034f56520f92ed434.tar.gz | |
amqp_channel:wait_for_confirms timeout is in seconds
See this line:
https://github.com/rabbitmq/rabbitmq-erlang-client/blob/master/src/amqp_channel.erl#L975-L977
| -rw-r--r-- | test/rabbit_stream_queue_SUITE.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/test/rabbit_stream_queue_SUITE.erl b/test/rabbit_stream_queue_SUITE.erl index 5ae4de82f4..1820e5229f 100644 --- a/test/rabbit_stream_queue_SUITE.erl +++ b/test/rabbit_stream_queue_SUITE.erl @@ -1037,7 +1037,7 @@ max_length_bytes(Config) -> #'confirm.select_ok'{} = amqp_channel:call(Ch, #'confirm.select'{}), amqp_channel:register_confirm_handler(Ch, self()), [publish(Ch, Q, Payload) || _ <- lists:seq(1, 100)], - amqp_channel:wait_for_confirms(Ch, 5000), + amqp_channel:wait_for_confirms(Ch, 5), %% We don't yet have reliable metrics, as the committed offset doesn't work %% as a counter once we start applying retention policies. @@ -1063,13 +1063,13 @@ max_age(Config) -> #'confirm.select_ok'{} = amqp_channel:call(Ch, #'confirm.select'{}), amqp_channel:register_confirm_handler(Ch, self()), [publish(Ch, Q, Payload) || _ <- lists:seq(1, 100)], - amqp_channel:wait_for_confirms(Ch, 5000), + amqp_channel:wait_for_confirms(Ch, 5), timer:sleep(10000), %% Let's publish again so the new segments will trigger the retention policy [publish(Ch, Q, Payload) || _ <- lists:seq(1, 100)], - amqp_channel:wait_for_confirms(Ch, 5000), + amqp_channel:wait_for_confirms(Ch, 5), timer:sleep(5000), |