Merge pull request #20 from DaPulse/feature/moshik/add_polling_wait_t…

…ime_ms_setter add setter to polling wait time ms
DaPulse · Apr 19, 2022 · f6d4444 · f6d4444
2 parents 90132aa + 737c075
commit f6d4444
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 2 deletions.
diff --git a/dist/consumer.d.ts b/dist/consumer.d.ts
@@ -55,6 +55,7 @@ export declare class Consumer extends EventEmitter {
     stop(): void;
     setBatchSize(newBatchSize: number): void;
     setConcurrencyLimit(newConcurrencyLimit: number): void;
+    setPollingWaitTimeMs(newPollingWaitTimeMs: number): void;
     reportMessageFromBatchFinished(message: SQSMessage, error: Error): Promise<void>;
     private reportNumberOfMessagesReceived;
     private handleSqsResponse;

diff --git a/dist/consumer.js b/dist/consumer.js
@@ -126,6 +126,9 @@ class Consumer extends events_1.EventEmitter {
         this.concurrencyLimit = newConcurrencyLimit;
         this.freeConcurrentSlots = newFreeConcurrentSlots;
     }
+    setPollingWaitTimeMs(newPollingWaitTimeMs) {
+        this.pollingWaitTimeMs = newPollingWaitTimeMs;
+    }
     async reportMessageFromBatchFinished(message, error) {
         debug('Message from batch has finished');
         this.freeConcurrentSlots++;

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "sqs-consumer",
-  "version": "6.1.0",
+  "version": "6.2.0",
   "description": "Build SQS-based Node applications without the boilerplate",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

diff --git a/src/consumer.ts b/src/consumer.ts
@@ -207,6 +207,10 @@ export class Consumer extends EventEmitter {
     this.freeConcurrentSlots = newFreeConcurrentSlots;
   }
 
+  public setPollingWaitTimeMs(newPollingWaitTimeMs: number): void {
+    this.pollingWaitTimeMs = newPollingWaitTimeMs;
+  }
+
   public async reportMessageFromBatchFinished(message: SQSMessage, error: Error): Promise<void> {
     debug('Message from batch has finished');