RedisAdapter - queue-redis documentation

Constructors

new



RedisAdapter(options: AdapterOptions)

private

readonly



configs: Map<string, QueueConfig>

private

readonly



defaultMaxAttempts: number

private

readonly



defaultVisibility: number

private

readonly



prefix: string

private

readonly



redis: RedisClient



ack(queue: string,
...ids: string[],
): Promise<void>



close(): Promise<void>

private



expireInflight(queue: string): Promise<void>

private



getConfig(queue: string): QueueConfig

private



key(queue: string,
suffix: string,
): string



nack(queue: string,
id: string,
options?: NackOptions,
): Promise<void>



receive<T>(queue: string,
count?: number,
): Promise<QueueMessage<T>[]>

private



routeToDlq(sourceQueue: string,
id: string,
dlqName: string,
): Promise<void>

Routes a message to the dead letter queue when attempt > maxAttempts. Mirrors in-memory adapter: messages DLQ'd after exceeding maxAttempts.



send<T>(queue: string,
data: T,
options?: SendOptions,
): Promise<string>