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 | |
| parent | f23a51261d9502ec39df0f8db47ba6b22aa7659f (diff) | |
| download | rabbitmq-server-git-43cfb45a74ec85fd51303a0765ebd272937077fb.tar.gz | |
Convert AMQP 091 timestamp to millisecond
For start offset in stream queue.
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_queue.erl | 2 | ||||
| -rw-r--r-- | deps/rabbit/test/rabbit_stream_queue_SUITE.erl | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index 4e428495b0..0e4654e59f 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -183,7 +183,7 @@ consume(Q, Spec, QState0) when ?amqqueue_is_stream(Q) -> {_, <<"next">>} -> next; {timestamp, V} -> - {timestamp, V}; + {timestamp, V * 1000}; {_, V} -> V end, 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, |