import { IQueueParams, QueueAcknowledgedMessages, QueueDeadLetteredMessages, QueuePendingMessages, QueuePublishedMessages, QueueScheduledMessages } from 'redis-smq';
import { GetQueueMessagesControllerRequestQueryDTO } from '../controllers/namespaces/namespace/queues/queue/messages/GetQueueMessagesControllerRequestQueryDTO.js';
import { CountQueueMessagesControllerRequestQueryDTO } from '../controllers/namespaces/namespace/queues/queue/messages/CountQueueMessagesControllerRequestQueryDTO.js';
import { PurgeQueueMessagesControllerRequestQueryDTO } from '../controllers/namespaces/namespace/queues/queue/messages/PurgeQueueMessagesControllerRequestQueryDTO.js';
export declare class QueueMessagesService {
    protected queuePublishedMessages: {
        countMessagesByStatusAsync: (queue: string | IQueueParams) => Promise<import("redis-smq").IQueuePublishedMessagesCountByStatus>;
        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>);
    } & QueuePublishedMessages;
    protected queueScheduledMessages: {
        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>);
    } & QueueScheduledMessages;
    protected queueAcknowledgedMessages: {
        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>);
    } & QueueAcknowledgedMessages;
    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;
    protected queueDeadLetteredMessages: {
        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>);
    } & QueueDeadLetteredMessages;
    constructor(queuePublishedMessages: QueuePublishedMessages, queueScheduledMessages: QueueScheduledMessages, queueAcknowledgedMessages: QueueAcknowledgedMessages, queuePendingMessages: QueuePendingMessages, queueDeadLetteredMessages: QueueDeadLetteredMessages);
    protected getMessageBrowser(status: GetQueueMessagesControllerRequestQueryDTO['status']): ({
        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) | ({
        countMessagesByStatusAsync: (queue: string | IQueueParams) => Promise<import("redis-smq").IQueuePublishedMessagesCountByStatus>;
        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>);
    } & QueuePublishedMessages) | ({
        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>);
    } & QueueScheduledMessages) | ({
        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>);
    } & QueueAcknowledgedMessages) | ({
        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>);
    } & QueueDeadLetteredMessages);
    getMessages(queueParams: IQueueParams, params: GetQueueMessagesControllerRequestQueryDTO): Promise<import("redis-smq").IBrowserPage<import("redis-smq").IMessageTransferable<unknown>>>;
    countMessages(queue: IQueueParams, params: CountQueueMessagesControllerRequestQueryDTO): Promise<number | import("redis-smq").IQueuePublishedMessagesCountByStatus>;
    purge(queueParams: IQueueParams, params: PurgeQueueMessagesControllerRequestQueryDTO): Promise<string>;
}
//# sourceMappingURL=QueueMessagesService.d.ts.map