Reviewed: https://review.opendev.org/c/openstack/oslo.messaging/+/908840 Committed: https://opendev.org/openstack/oslo.messaging/commit/5988c7bf141ecbf319236dffc2c0ab32c3f7393e Submitter: "Zuul (22348)" Branch: master
commit 5988c7bf141ecbf319236dffc2c0ab32c3f7393e Author: Guillaume Espanel <email address hidden> Date: Wed Jan 24 12:11:56 2024 +0100
Restore read stream queues from last known offset
When an agent reconnected to a rabbitmq server, it would start consumming messages from the last offset available in the stream.
This could cause important messages to be lost.
With this patch, oslo_messaging will keep track of the last consummed offset and restore reading from that point.
Related-bug: #2031497
Change-Id: I449008829b0c0a1a759c211b83f7a99d9c7f2c0d
Reviewed: https:/ /review. opendev. org/c/openstack /oslo.messaging /+/908840 /opendev. org/openstack/ oslo.messaging/ commit/ 5988c7bf141ecbf 319236dffc2c0ab 32c3f7393e
Committed: https:/
Submitter: "Zuul (22348)"
Branch: master
commit 5988c7bf141ecbf 319236dffc2c0ab 32c3f7393e
Author: Guillaume Espanel <email address hidden>
Date: Wed Jan 24 12:11:56 2024 +0100
Restore read stream queues from last known offset
When an agent reconnected to a rabbitmq server, it would start
consumming messages from the last offset available in the stream.
This could cause important messages to be lost.
With this patch, oslo_messaging will keep track of the last consummed
offset and restore reading from that point.
Related-bug: #2031497
Change-Id: I449008829b0c0a 1a759c211b83f7a 99d9c7f2c0d