tree 38b54885e578cde2967f65b272ea1c2935dc85d8
parent 30ef8e2467aeaf9bd1f965e104436e0f97960ab1
author David Åkerman <davidak@axis.com> 1740153169 +0100
committer David Åkerman <davidak@axis.com> 1755773247 +0200

Add support for RabbitMQ streams

With streams you will be able to use the replay
functionality. To keep track of the current message an
offset is used. The offset is periodically saved/stored and
when replayAll is called the consumer start to consume from the
beginning of the stream.
Every stream.windowSize we store
(current offset - stream.windowSize) as the offset to make
sure we replay missed messages when we restart a multi-site
instance.

Change-Id: I51a49533248ce94d1e6831071b033869c86db6d8