basalt / queue-sqs/src / SqsApi

Interface: SqsApi

Defined in: queue-sqs/src/index.ts:20

The SQS operations this driver uses. Injectable so tests need no broker.

Methods

deleteMessage()

> deleteMessage(input): Promise<void>

Defined in: queue-sqs/src/index.ts:33

Parameters

input

queueUrl

string

receiptHandle

string

Returns

Promise<void>

---

receiveMessages()

> receiveMessages(input): Promise<SqsMessage[]>

Defined in: queue-sqs/src/index.ts:27

Parameters

input

maxMessages

number

queueUrl

string

visibilityTimeout

number

waitTimeSeconds

number

Returns

Promise<SqsMessage[]>

---

sendMessage()

> sendMessage(input): Promise<void>

Defined in: queue-sqs/src/index.ts:21

Parameters

input

attributes?

Record<string, string>

body

string

delaySeconds?

number

queueUrl

string

Returns

Promise<void>