Class InMemoryTaskMessageQueue`Experimental`

In-memory TaskMessageQueue implementation for development and testing. For production, use Redis or another distributed queue.

Implements

TaskMessageQueue

Index

Constructors

Methods

dequeue dequeueAll enqueue

Constructors

constructor

new InMemoryTaskMessageQueue(): InMemoryTaskMessageQueue
Experimental
Returns InMemoryTaskMessageQueue

Methods

dequeue

dequeue(taskId: string, sessionId?: string): Promise<QueuedMessage | undefined>
Experimental
Removes and returns the first message from the queue for a specific task.
Parameters
- taskId: string
  The task identifier
- OptionalsessionId: string
  Optional session ID for binding the query to a specific session
Returns Promise<QueuedMessage | undefined>
The first message, or undefined if the queue is empty
Implementation of TaskMessageQueue.dequeue
- Defined in packages/core/src/experimental/tasks/stores/inMemory.ts:296

dequeueAll

dequeueAll(taskId: string, sessionId?: string): Promise<QueuedMessage[]>
Experimental
Removes and returns all messages from the queue for a specific task.
Parameters
- taskId: string
  The task identifier
- OptionalsessionId: string
  Optional session ID for binding the query to a specific session
Returns Promise<QueuedMessage[]>
Array of all messages that were in the queue
Implementation of TaskMessageQueue.dequeueAll
- Defined in packages/core/src/experimental/tasks/stores/inMemory.ts:307

enqueue

enqueue(
    taskId: string,
    message: QueuedMessage,
    sessionId?: string,
    maxSize?: number,
): Promise<void>
Experimental
Adds a message to the end of the queue for a specific task. Atomically checks queue size and throws if maxSize would be exceeded.
Parameters
- taskId: string
  The task identifier
- message: QueuedMessage
  The message to enqueue
- OptionalsessionId: string
  Optional session ID for binding the operation to a specific session
- OptionalmaxSize: number
  Optional maximum queue size - if specified and queue is full, throws an error
Returns Promise<void>
Throws
Error if maxSize is specified and would be exceeded
Implementation of TaskMessageQueue.enqueue
- Defined in packages/core/src/experimental/tasks/stores/inMemory.ts:279