Fix typing issue

weyoss · Jun 18, 2022 · cd8bf6a · cd8bf6a
1 parent 02c353d
commit cd8bf6a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/lib/consumer/consumer-message-handler/dequeue-message.ts b/src/lib/consumer/consumer-message-handler/dequeue-message.ts
@@ -52,7 +52,7 @@ export class DequeueMessage {
     this.ticker = new Ticker(() => this.dequeue());
   }
 
-  protected dequeueMessageWithPriority(cb: ICallback<string>): void {
+  protected dequeueMessageWithPriority(cb: ICallback<string | null>): void {
     this.redisClient.zpophgetrpush(
       this.redisKeys.keyQueuePendingPriorityMessageWeight,
       this.redisKeys.keyQueuePendingPriorityMessages,