RedisAdapter - default - queue-redis documentation

class RedisAdapter

implements QueueAdapter

Redis-backed queue adapter using sorted sets for ordering and visibility timeout.

Constructors



RedisAdapter(options: AdapterOptions)



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



close(): Promise<void>



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



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



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



sendBatch<T>(queue: string,
data: T[],
options?: SendOptions
): Promise<string[]>