Skip to content

Commit 505b555

Browse files
author
Weyoss
committed
refactor(redis-smq): rename IQueueMessages interface to IQueueMessageManager
1 parent 20d9985 commit 505b555

3 files changed

Lines changed: 8 additions & 7 deletions

File tree

packages/redis-smq/src/lib/queue-messages/queue-messages-manager/queue-messages-manager-abstract.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import { IQueueParsedParams, TQueueExtendedParams } from '../../queue/index.js';
2222
import { _validateQueueExtendedParams } from '../_/_validate-queue-extended-params.js';
2323
import { QueueMessagesStorage } from '../queue-messages-storage/queue-messages-storage.js';
2424
import {
25-
IQueueMessages,
25+
IQueueMessageManager,
2626
IQueueMessagesPage,
2727
IQueueMessagesPageParams,
2828
} from '../types/index.js';
@@ -31,7 +31,9 @@ import {
3131
* Abstract base class for queue message management operations.
3232
* Provides common functionality for different types of queue message managers.
3333
*/
34-
export abstract class QueueMessagesManagerAbstract implements IQueueMessages {
34+
export abstract class QueueMessagesManagerAbstract
35+
implements IQueueMessageManager
36+
{
3537
/**
3638
* Redis client instance for database operations.
3739
*/

packages/redis-smq/src/lib/queue-messages/queue-messages/queue-pending-messages/queue-pending-messages.ts

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,12 +17,11 @@ import {
1717
IQueueParsedParams,
1818
TQueueExtendedParams,
1919
} from '../../../queue/index.js';
20-
import { QueueMessagesManagerAbstract } from '../../queue-messages-manager/queue-messages-manager-abstract.js';
21-
import { IQueueMessages, IQueueMessagesPage } from '../../types/index.js';
20+
import { IQueueMessageManager, IQueueMessagesPage } from '../../types/index.js';
2221
import { SequentialQueuePendingMessages } from './sequential-queue-pending-messages.js';
2322
import { PriorityQueuePendingMessages } from './priority-queue-pending-messages.js';
2423

25-
export class QueuePendingMessages implements IQueueMessages {
24+
export class QueuePendingMessages implements IQueueMessageManager {
2625
protected redisClient;
2726
protected priorityQueueMessages;
2827
protected sequentialQueuePendingMessages;
@@ -35,7 +34,7 @@ export class QueuePendingMessages implements IQueueMessages {
3534

3635
protected getQueueImplementation(
3736
queue: IQueueParsedParams,
38-
cb: ICallback<QueueMessagesManagerAbstract>,
37+
cb: ICallback<IQueueMessageManager>,
3938
): void {
4039
this.redisClient.getSetInstance((err, client) => {
4140
if (err) cb(err);

packages/redis-smq/src/lib/queue-messages/types/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import { ICallback } from 'redis-smq-common';
1111
import { IMessageTransferable } from '../../message/index.js';
1212
import { IQueueParams, TQueueExtendedParams } from '../../queue/index.js';
1313

14-
export interface IQueueMessages {
14+
export interface IQueueMessageManager {
1515
countMessages(queue: TQueueExtendedParams, cb: ICallback<number>): void;
1616
getMessages(
1717
queue: TQueueExtendedParams,

0 commit comments

Comments
 (0)