import { FSM } from '@dra2020/baseclient'; import { Environment } from '../sqs/env'; import { SQSMessage } from '../sqs/sqsmessage'; import { AgentPool } from './agentpool'; import { MessageData, MessageParams } from './messageparams'; declare class FsmClientRequest extends FSM.Fsm { client: SimpleSQSClient; httpoptions: any; params: MessageParams; request: any; response: any; statusCode: number; bufs: Buffer[]; body: any; constructor(env: Environment, client: SimpleSQSClient, params: MessageParams); get env(): Environment; onDone(): void; onError(msg: string): void; tick(): void; } export declare class FsmClientSend extends FsmClientRequest { constructor(env: Environment, client: SimpleSQSClient, batch: MessageData[]); end(): void; } export declare class FsmClientReceive extends FsmClientRequest { results: SQSMessage[]; constructor(env: Environment, client: SimpleSQSClient, queueName: string); end(): void; } export declare class FsmClientQueueSend extends FSM.Fsm { md: MessageData; constructor(env: Environment, md: MessageData); sent(fsmSend: FsmClientSend): void; tick(): void; } export declare class SimpleSQSClient { env: Environment; targeturl: any; httpoptions: any; agentPool: AgentPool; fsmSendQueued: FsmClientQueueSend[]; fsmSendOutstanding: FsmClientSend; constructor(env: Environment, urlstring?: string); checkQueue(): void; allocOptions(): any; freeOptions(options: any): void; send(queueName: string, message: SQSMessage): FsmClientQueueSend; receive(queueName: string): FsmClientReceive; } export {};