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 a SIGINT signal is sent to the process running the consumer while it is processing a message, the consumer behaves as follows:
Waits for AWS requests to stop (primarily long polling).
Emits the stopped event.
This leads to the following situation:
There is no way for consumers of the library to ensure that an in-flight message finishes processing before the stopped event is emitted.
It appears that both the heartbeat and visibility timeout extensions stop as well. Even when adding custom logic to emit a separate stopped event after message processing completes, the acknowledgment and deletion steps fail with an error like:
SQSError: Error changing visibility timeout: Value ... for parameter ReceiptHandle is invalid.
Reason: Message does not exist or is not available for visibility timeout change
Question
Before assuming this is a bug, I wanted to ask whether this behavior is by design.
Should consumers expect this shutdown behavior when handling in-flight messages?
Thank you for the hard work and for providing such a solid and reliable wrapper! 🙏
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
-
Summary
Description
When a SIGINT signal is sent to the process running the consumer while it is processing a message, the consumer behaves as follows:
This leads to the following situation:
Question
Before assuming this is a bug, I wanted to ask whether this behavior is by design.
Should consumers expect this shutdown behavior when handling in-flight messages?
Thank you for the hard work and for providing such a solid and reliable wrapper! 🙏
Example
No response
Beta Was this translation helpful? Give feedback.
All reactions