diff options
| -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 f1673a21ff..223e19c713 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, |