import { FSM, LogAbstract } from '@dra2020/baseclient'; import { Environment } from '../sqs/env'; import { SQSManagerBase } from '../sqs/sqsmanager'; import { FsmSend, FsmReceive } from '../sqs/sqsfsm'; import { SQSMessage } from '../sqs/sqsmessage'; import { SQSOptions } from '../sqs/sqsoptions'; import { SQSBlob } from '../sqs/sqsblob'; import * as Client from './client'; declare class FsmQueue extends FSM.Fsm { client: Client.SimpleSQSClient; tailQueue: Map; options: SQSOptions; queueName: string; err: any; constructor(env: Environment, client: Client.SimpleSQSClient, options: SQSOptions); } export declare class FsmSendSimple extends FsmSend { q: FsmQueue; err: any; dataString: string; trace: LogAbstract.AsyncTimer; fsmSend: Client.FsmClientQueueSend; constructor(env: Environment, q: FsmQueue, m: SQSMessage); get env(): Environment; tick(): void; } export declare class FsmReceiveSimple extends FsmReceive { err: any; q: FsmQueue; blobs: SQSBlob[]; trace: LogAbstract.AsyncTimer; fsmReceive: Client.FsmClientReceive; constructor(env: Environment, q: FsmQueue); get env(): Environment; tick(): void; } export declare class SimpleSQSManager extends SQSManagerBase { nameToQueue: Map; client: Client.SimpleSQSClient; constructor(env: Environment, url?: string); toQueueName(n: string): string; reportError(call: string, err: any): void; queueOf(queueName: string): FsmQueue; send(queueName: string, m: SQSMessage): FsmSend; receive(queueName: string): FsmReceive; delete(queueName: string, m: SQSMessage): any; } export {};