sqs-consumer
sqs-consumer copied to clipboard
Build Amazon Simple Queue Service (SQS) based applications without the boilerplate
**Describe the bug** If the AWS credential are missing, but the AWS_WEB_IDENTITY_TOKEN_FILE is present there seems to get an access denied error. The application is deployed with Kubernetes and the...
**The problem** Amazon SQS can only support messages up to 256KB in size. To handle large messages (up to 2GB), the AWS docs recommend using their [Extended Java Client Library](https://github.com/awslabs/amazon-sqs-java-extended-client-lib)...
**Describe the bug** According to usage docs: > Throwing an error (or returning a rejected promise) from the handler function will cause the message to be left on the queue....
**Hello guys!** I am using this package to receive data from AWS IoT Core. The messages are properly transferred to the backend but I do not know which exactly device...
I want to implement graceful reload like this : 1. Restart the server 2. Stop polling 3. Finish the current jobs 4. Start polling i checked the doc found this...
Based on a code from master branch: ``` public start(): void { if (this.stopped) { debug('Starting consumer'); this.stopped = false; this.poll(); } } public stop(): void { debug('Stopping consumer'); this.stopped...
**Describe the bug** On occasion, the changeMessageVisibility can be called right after the message has been deleted. **To Reproduce** Set the heartbeatInterval and hope to reproduce the issue. **Expected behaviour**...
**Describe the problem** The README should include the `sqs:ChangeMessageVisibility` IAM permission. This permission is used by the following lines of code: * https://github.com/bbc/sqs-consumer/blob/v5.6.0/src/consumer.ts#L279 * https://github.com/bbc/sqs-consumer/blob/v5.6.0/src/consumer.ts#L401 **To Reproduce** Steps to reproduce...
**Describe the bug** A clear and concise description of what the bug is. **To Reproduce** Steps to reproduce the behaviour: 1. Setup a node server and use @aws-sdk/client-sqs 2. setup...
## Description Adds a missing `await` to ensure that the error-handling code in `changeVisibilityTimeout` actually works. ## Motivation and Context We recently saw a bunch of unhandled promise rejections, and...