interface ISqsTransport

Domain port for SQS operations. The adapter depends on this, not the SDK.

Methods

send(
queueUrl: string,
body: string,
delaySeconds?: number
): Promise<void>

Send a message to a queue.

receive(
queueUrl: string,
max: number,
visibilitySeconds: number
): Promise<readonly SqsReceivedMessage[]>

Receive messages from a queue.

delete(
queueUrl: string,
receiptHandle: string
): Promise<void>

Delete a message (ack).

changeVisibility(
queueUrl: string,
receiptHandle: string,
seconds: number
): Promise<void>

Change visibility timeout (requeue).

Since 0.1.0
optional
isHealthy(): Promise<boolean>

M70c: reports whether the queue is reachable — the real adapter issues GetQueueAttributes. Optional so a minimal injected fake still type-checks; a transport that omits it is unknown, not false.

close(): Promise<void>

Close the client.

Usage

import { type ISqsTransport } from "queue-plugin/src/index.ts";