refactor(QueueMessages)!: remove redundant method deleteMessage()

weyoss · Dec 9, 2023 · af21dff · af21dff
1 parent 8279840
commit af21dff
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 28 deletions.
diff --git a/src/lib/queue/queue-messages-paginator/queue-messages-paginator-abstract.ts b/src/lib/queue/queue-messages-paginator/queue-messages-paginator-abstract.ts
@@ -114,16 +114,4 @@ export abstract class QueueMessagesPaginatorAbstract implements IQueueMessages {
       }
     });
   }
-
-  deleteMessage(
-    queue: string | IQueueParams,
-    messageId: string | string[],
-    cb: ICallback<void>,
-  ): void {
-    _getCommonRedisClient((err, client) => {
-      if (err) cb(err);
-      else if (!client) cb(new CallbackEmptyReplyError());
-      else _deleteMessage(client, messageId, cb);
-    });
-  }
 }
diff --git a/src/lib/queue/queue-pending-messages.ts b/src/lib/queue/queue-pending-messages.ts
@@ -71,17 +71,6 @@ export class QueuePendingMessages implements IQueueMessages {
     });
   }
 
-  deleteMessage(
-    queue: string | IQueueParams,
-    messageId: string,
-    cb: ICallback<void>,
-  ): void {
-    this.getQueueImplementation(queue, (err, pendingMessages) => {
-      if (err) cb(err);
-      else pendingMessages?.deleteMessage(queue, messageId, cb);
-    });
-  }
-
   purge(queue: string | IQueueParams, cb: ICallback<void>): void {
     this.getQueueImplementation(queue, (err, pendingMessages) => {
       if (err) cb(err);

diff --git a/types/queue-messages/index.ts b/types/queue-messages/index.ts
@@ -20,11 +20,6 @@ export interface IQueueMessages {
     cb: ICallback<IQueueMessagesPage<Message>>,
   ): void;
   purge(queue: string | IQueueParams, cb: ICallback<void>): void;
-  deleteMessage(
-    queue: string | IQueueParams,
-    messageId: string,
-    cb: ICallback<void>,
-  ): void;
 }
 
 export interface IQueueMessagesCount {