diff options
Diffstat (limited to 'deps/rabbit/src')
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_queue.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index d130c7225b..4e428495b0 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -182,6 +182,8 @@ consume(Q, Spec, QState0) when ?amqqueue_is_stream(Q) -> last; {_, <<"next">>} -> next; + {timestamp, V} -> + {timestamp, V}; {_, V} -> V end, @@ -219,6 +221,7 @@ begin_stream(#stream_client{readers = Readers0} = State, first -> NextOffset; last -> NextOffset; next -> NextOffset; + {timestamp, _} -> NextOffset; _ -> Offset end, Str0 = #stream{name = amqqueue:get_name(Q), |