Merge pull request #2 from DaPulse/feature/ran/add_timeout_for_zero_batch_size

Feature/ran/add timeout for zero batch size

Author: RanNir143

dist/consumer.d.ts

@@ -12,6 +12,7 @@ export interface ConsumerOptions {
     waitTimeSeconds?: number;
     authenticationErrorTimeout?: number;
     pollingWaitTimeMs?: number;
+    pollingWaitTimeMsBatchSizeZero?: number;
     terminateVisibilityTimeout?: boolean;
     sqs?: SQS;
     region?: string;
@@ -39,6 +40,7 @@ export declare class Consumer extends EventEmitter {
     private waitTimeSeconds;
     private authenticationErrorTimeout;
     private pollingWaitTimeMs;
+    private pollingWaitTimeMsBatchSizeZero;
     private terminateVisibilityTimeout;
     private sqs;
     constructor(options: ConsumerOptions);

dist/consumer.js

@@ -79,6 +79,7 @@ class Consumer extends events_1.EventEmitter {
         this.waitTimeSeconds = options.waitTimeSeconds || 20;
         this.authenticationErrorTimeout = options.authenticationErrorTimeout || 10000;
         this.pollingWaitTimeMs = options.pollingWaitTimeMs || 0;
+        this.pollingWaitTimeMsBatchSizeZero = options.pollingWaitTimeMsBatchSizeZero || 5;
         this.sqs =
             options.sqs ||
                 new SQS({
@@ -292,7 +293,7 @@ class Consumer extends events_1.EventEmitter {
             });
         }
         else {
-            setTimeout(this.poll, currentPollingTimeout);
+            setTimeout(this.poll, this.pollingWaitTimeMsBatchSizeZero);
         }
     }
     async processMessageBatch(messages) {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sqs-consumer",
-  "version": "5.7.6",
+  "version": "5.7.7",
   "description": "Build SQS-based Node applications without the boilerplate",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/consumer.ts

@@ -89,6 +89,7 @@ export interface ConsumerOptions {
   waitTimeSeconds?: number;
   authenticationErrorTimeout?: number;
   pollingWaitTimeMs?: number;
+  pollingWaitTimeMsBatchSizeZero?: number;
   terminateVisibilityTimeout?: boolean;
   sqs?: SQS;
   region?: string;
@@ -117,6 +118,7 @@ export class Consumer extends EventEmitter {
   private waitTimeSeconds: number;
   private authenticationErrorTimeout: number;
   private pollingWaitTimeMs: number;
+  private pollingWaitTimeMsBatchSizeZero: number;
   private terminateVisibilityTimeout: boolean;
   private sqs: SQS;
 
@@ -140,6 +142,7 @@ export class Consumer extends EventEmitter {
     this.waitTimeSeconds = options.waitTimeSeconds || 20;
     this.authenticationErrorTimeout = options.authenticationErrorTimeout || 10000;
     this.pollingWaitTimeMs = options.pollingWaitTimeMs || 0;
+    this.pollingWaitTimeMsBatchSizeZero = options.pollingWaitTimeMsBatchSizeZero || 5;
 
     this.sqs =
       options.sqs ||
@@ -371,7 +374,7 @@ export class Consumer extends EventEmitter {
           this.emit('error', err);
         });
     } else {
-      setTimeout(this.poll, currentPollingTimeout);
+      setTimeout(this.poll, this.pollingWaitTimeMsBatchSizeZero);
     }
   }