You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When receiveMessages() is called we resolve the returned promise in the below scenarios
required number of messages are collected
or the wait time that was provided has elapsed
or more than 1 sec has passed since last message was received
In the second and third cases, it can be possible that rhea received a message, fired the message event which then got ignored because we removed the listeners in preparation to resolve the promise. Such in flight messages get ignored, which is not a big deal in peek lock mode, but results in data loss in case of receive and delete mode.
This issue is to first investigate if the above is possible and then to explore solutions.
This issue is a follow up from #6004 (review)
When
receiveMessages()
is called we resolve the returned promise in the below scenariosIn the second and third cases, it can be possible that rhea received a message, fired the
message
event which then got ignored because we removed the listeners in preparation to resolve the promise. Such in flight messages get ignored, which is not a big deal in peek lock mode, but results in data loss in case of receive and delete mode.This issue is to first investigate if the above is possible and then to explore solutions.
cc @ramya0820
The text was updated successfully, but these errors were encountered: