import { SQSConfig } from '../../../../typings/config'; import { SQSPriorities } from '../../../../typings/manager'; import { ARN, EventItem, MessageAttributeMap } from '../../../client'; import { BaseManager } from '../../common/model/base-manager'; import { BaseStorageEngine } from '../../common/model/base-storage-engine'; import { Queue } from '../../common/model/queue'; import { User } from '../../common/model/user'; export declare class SQSManager extends BaseManager { static DEFAULT_PRIORITIES: SQSPriorities; static DISABLE_RECEIVE_MESSAGE: boolean; private requestClient; private readonly _sQSStorageEngine; private _eventQueue; private storageToQueueWorker; private addEventInQueueListener; private static addToPriorities; private static prometheusARN; get eventStats(): Record; prometheus(time?: Date): string; constructor(sqsConfig: SQSConfig); comparatorFunction(queueARN: string, value: (event1: EventItem, event2: EventItem) => boolean): void; poll(queue: Queue, visibilityTimeout: number): Promise; resetAll(resetOnlyStatistics?: boolean): void; updateEvent(queue: Queue, event: EventItem): Promise; updateEventStateSuccess(queue: Queue, id: string, message: string): Promise; updateEventStateFailure(queue: Queue, id: string, message: string): Promise; listQueues(queueARNPrefix: ARN): Promise>; createQueue(user: User, queueName: string, region: string, attributes: Record, tag: Record): Promise; getQueue(queueARN: ARN): Promise; deleteQueue(queue: Queue): Promise; sendMessage(queue: Queue, MessageBody: string, MessageAttribute: MessageAttributeMap, MessageSystemAttribute: MessageAttributeMap, DelaySeconds_?: string, MessageDeduplicationId?: string): Promise; receiveMessage(queue: Queue, VisibilityTimeout?: string, MaxNumberOfMessages?: string): Promise>; cancel(): void; getStorageEngine(): BaseStorageEngine; findMessageById(queue: Queue, messageId: string): Promise; findMessageByDeduplicationId(queue: Queue, messageDeduplicationId: string): Promise; private pollN; private addItemInQueue; }