diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-11-27 14:47:36 +0100 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-11-27 14:47:36 +0100 |
| commit | 43cfb45a74ec85fd51303a0765ebd272937077fb (patch) | |
| tree | efe60b453bd2b96f1ce9a360bccb8d91d4c2f087 /deps/rabbit/test/rabbit_stream_queue_SUITE.erl | |
| parent | f23a51261d9502ec39df0f8db47ba6b22aa7659f (diff) | |
| download | rabbitmq-server-git-43cfb45a74ec85fd51303a0765ebd272937077fb.tar.gz | |
Convert AMQP 091 timestamp to millisecond
For start offset in stream queue.
Diffstat (limited to 'deps/rabbit/test/rabbit_stream_queue_SUITE.erl')
| -rw-r--r-- | deps/rabbit/test/rabbit_stream_queue_SUITE.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/test/rabbit_stream_queue_SUITE.erl b/deps/rabbit/test/rabbit_stream_queue_SUITE.erl index a1055458db..25f3c05c66 100644 --- a/deps/rabbit/test/rabbit_stream_queue_SUITE.erl +++ b/deps/rabbit/test/rabbit_stream_queue_SUITE.erl @@ -619,7 +619,7 @@ consume_timestamp_offset(Config) -> Ch1 = rabbit_ct_client_helpers:open_channel(Config, Server), qos(Ch1, 10, false), - Offset = erlang:system_time(millisecond) - 600000, + Offset = erlang:system_time(second) - 60, amqp_channel:subscribe( Ch1, #'basic.consume'{queue = Q, @@ -653,7 +653,7 @@ consume_timestamp_last_offset(Config) -> qos(Ch1, 10, false), %% Subscribe from now/future - Offset = erlang:system_time(millisecond) + 60000, + Offset = erlang:system_time(second) + 60, amqp_channel:subscribe( Ch1, #'basic.consume'{queue = Q, |