dag-adapters-local / Exports / InMemoryQueuePort
Class: InMemoryQueuePort
Implements
IQueuePort
Table of contents
Constructors
Methods
Constructors
constructor
• new InMemoryQueuePort(): InMemoryQueuePort
Returns
Methods
enqueue
▸ enqueue(message): Promise<void>
Parameters
| Name | Type |
|---|---|
message | IQueueMessage |
Returns
Promise<void>
Implementation of
IQueuePort.enqueue
Defined in
dequeue
▸ dequeue(workerId, visibilityTimeoutMs): Promise<undefined | IQueueMessage>
Parameters
| Name | Type |
|---|---|
workerId | string |
visibilityTimeoutMs | number |
Returns
Promise<undefined | IQueueMessage>
Implementation of
IQueuePort.dequeue
Defined in
ack
▸ ack(messageId): Promise<void>
Parameters
| Name | Type |
|---|---|
messageId | string |
Returns
Promise<void>
Implementation of
IQueuePort.ack
Defined in
nack
▸ nack(messageId): Promise<void>
Parameters
| Name | Type |
|---|---|
messageId | string |
Returns
Promise<void>
Implementation of
IQueuePort.nack