diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-10-09 16:54:20 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-10-09 16:54:20 +0200 |
| commit | bdbd3258bee95edf2696719745ebfd1c6b09f630 (patch) | |
| tree | ac017e4e66885db36c900c8f63aa8257508542c8 | |
| parent | 424d3158fb0b176b1f3a018c0a7d779531616416 (diff) | |
| download | rabbitmq-server-git-bdbd3258bee95edf2696719745ebfd1c6b09f630.tar.gz | |
Fix start offset for first offset consuming
| -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 |