summaryrefslogtreecommitdiff
path: root/deps/rabbit/test/rabbit_stream_queue_SUITE.erl
Commit message (Collapse)AuthorAgeFilesLines
* Bump (c) yearMichael Klishin2021-01-221-1/+1
|
* Stream: Channel resend on leader changekjnilsson2021-01-131-0/+104
| | | | | | | | Detect when a new stream leader is elected and make stream_queues re-send any unconfirmed, pending messages to ensure they did not get lost during the leader change. This is done using the osiris deduplication feature to ensure the resend does not create duplicates of messages in the stream.
* Apply retention policy in all osiris membersdcorbacho2021-01-121-8/+32
|
* Update retention when only stream retention policy has changeddcorbacho2021-01-121-0/+10
| | | | In any other case, the worker needs to be restarted
* Convert AMQP 091 timestamp to millisecondArnaud Cogoluègnes2020-11-271-2/+2
| | | | For start offset in stream queue.
* Merge remote-tracking branch 'origin/master' into stream-timestamp-offsetstream-timestamp-offsetdcorbacho2020-11-181-0/+83
|
* Change repo "root" to deps/rabbitPhilip Kuryloski2020-11-131-0/+1527
rabbit must not be the monorepo root application, as other applications depend on it