import { FSM, LogAbstract } from '@dra2020/baseclient'; import { Environment } from './env'; import { SQSBlob } from './sqsblob'; import { SQSMessage } from './sqsmessage'; import { FsmSend, FsmReceive, FsmDelete } from './sqsfsm'; import { SQSManagerBase } from './sqsmanager'; import { SQSOptions } from './sqsoptions'; declare class FsmQueue extends FSM.Fsm { sqsManager: SQSManager; tailQueue: Map; options: SQSOptions; url: string; err: any; constructor(env: Environment, sqsManager: SQSManager, options: SQSOptions); get env(): Environment; finish(url: string): void; tick(): void; } export declare class FsmSendSQS extends FsmSend { q: FsmQueue; err: any; dataString: string; trace: LogAbstract.AsyncTimer; constructor(env: Environment, q: FsmQueue, m: SQSMessage); tick(): void; } export declare class FsmReceiveSQS extends FsmReceive { err: any; q: FsmQueue; blobs: SQSBlob[]; trace: LogAbstract.AsyncTimer; constructor(env: Environment, q: FsmQueue); tick(): void; } export declare class FsmDeleteSQS extends FsmDelete { q: FsmQueue; err: any; constructor(env: Environment, q: FsmQueue, m: SQSMessage); tick(): void; } export declare class SQSManager extends SQSManagerBase { env: Environment; sqs: any; nameToQueue: Map; constructor(env: Environment, options?: SQSOptions); toQueueName(n: string): string; reportError(call: string, err: any): void; queueOf(name: string): FsmQueue; send(name: string, m: SQSMessage): FsmSend; receive(name: string): FsmReceive; delete(name: string, m: SQSMessage): FsmDelete; } export {};