diff options
| -rw-r--r-- | src/rabbit_stream_queue.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_stream_queue.erl b/src/rabbit_stream_queue.erl index 612bf81d00..394479a8f2 100644 --- a/src/rabbit_stream_queue.erl +++ b/src/rabbit_stream_queue.erl @@ -206,6 +206,7 @@ begin_stream(#stream_client{readers = Readers0} = State, osiris:register_offset_listener(LocalPid, NextOffset), %% TODO: avoid double calls to the same process StartOffset = case Offset of + first -> NextOffset; last -> NextOffset; next -> NextOffset; _ -> Offset |