import { ConsumerGroups, IQueueParams, QueuePendingMessages } from 'redis-smq';
export declare class ConsumerGroupsService {
    protected consumerGroups: {
        saveConsumerGroupAsync: (queue: string | IQueueParams, groupId: string) => Promise<number>;
        deleteConsumerGroupAsync: ((queue: string | IQueueParams, groupId: string) => Promise<undefined>) | ((queue: string | IQueueParams, groupId: string) => Promise<void>);
        getConsumerGroupsAsync: (queue: string | IQueueParams) => Promise<string[]>;
    } & ConsumerGroups;
    protected queuePendingMessages: {
        countMessagesAsync: (queue: import("redis-smq").TQueueExtendedParams) => Promise<number>;
        getMessageIdsAsync: (queue: import("redis-smq").TQueueExtendedParams, page: number, pageSize: number) => Promise<import("redis-smq").IBrowserPage<string>>;
        getMessagesAsync: (queue: import("redis-smq").TQueueExtendedParams, page: number, pageSize: number) => Promise<import("redis-smq").IBrowserPage<import("redis-smq").IMessageTransferable<unknown>>>;
        purgeAsync: (queue: import("redis-smq").TQueueExtendedParams) => Promise<string>;
        cancelPurgeAsync: ((queue: import("redis-smq").TQueueExtendedParams, jobId: string) => Promise<undefined>) | ((queue: import("redis-smq").TQueueExtendedParams, jobId: string) => Promise<void>);
        getPurgeJobAsync: (queue: import("redis-smq").TQueueExtendedParams, jobId: string) => Promise<import("redis-smq").TPurgeQueueJob>;
        getPurgeJobStatusAsync: ((queue: import("redis-smq").TQueueExtendedParams, jobId: string) => Promise<import("redis-smq").EBackgroundJobStatus.PENDING>) | ((queue: import("redis-smq").TQueueExtendedParams, jobId: string) => Promise<import("redis-smq").EBackgroundJobStatus.PROCESSING>) | ((queue: import("redis-smq").TQueueExtendedParams, jobId: string) => Promise<import("redis-smq").EBackgroundJobStatus.COMPLETED>) | ((queue: import("redis-smq").TQueueExtendedParams, jobId: string) => Promise<import("redis-smq").EBackgroundJobStatus.FAILED>) | ((queue: import("redis-smq").TQueueExtendedParams, jobId: string) => Promise<import("redis-smq").EBackgroundJobStatus.CANCELED>);
    } & QueuePendingMessages;
    constructor(consumerGroups: ConsumerGroups, queuePendingMessages: QueuePendingMessages);
    deleteConsumerGroup(queueParams: IQueueParams, consumerGroupId: string): Promise<void>;
    getConsumerGroups(queueParams: IQueueParams): Promise<string[]>;
    saveConsumerGroup(queueParams: IQueueParams, consumerGroupId: string): Promise<void>;
    getPendingMessages(queueParams: IQueueParams, consumerGroupId: string, page: number, pageSize: number): Promise<import("redis-smq").IBrowserPage<import("redis-smq").IMessageTransferable<unknown>>>;
    countPendingMessages(queueParams: IQueueParams, consumerGroupId: string): Promise<number>;
    purgePendingMessages(queueParams: IQueueParams, consumerGroupId: string): Promise<void>;
}
//# sourceMappingURL=ConsumerGroupsService.d.ts.map