dag-core / Exports / IQueuePort

Interface: IQueuePort

Port for task queue operations: enqueue, dequeue, acknowledge, and reject.

Table of contents

Methods

• enqueue
• dequeue
• ack
• nack

Methods

enqueue

▸ enqueue(message): Promise<void>

Parameters

Name	Type
message	IQueueMessage

Returns

Promise<void>

Defined in

interfaces/ports.ts:58

---

dequeue

▸ dequeue(workerId, visibilityTimeoutMs): Promise<undefined | IQueueMessage>

Parameters

Name	Type
workerId	string
visibilityTimeoutMs	number

Returns

Promise<undefined | IQueueMessage>

Defined in

interfaces/ports.ts:59

---

ack

▸ ack(messageId): Promise<void>

Parameters

Name	Type
messageId	string

Returns

Promise<void>

Defined in

interfaces/ports.ts:60

---

nack

▸ nack(messageId): Promise<void>

Parameters

Name	Type
messageId	string

Returns

Promise<void>

Defined in

interfaces/ports.ts:61