Documentation / @tenancy-node/transport-redis-streams / consumeRedisStream

Function: consumeRedisStream()

consumeRedisStream(options): object

Defined in: index.ts:89

Consume eventos de un stream con un grupo: confirma (XACK) solo después de procesar. Un mensaje que falla maxAttempts veces, o que no trae un campo event válido, se confirma (y se copia a deadLetterStream si se indicó) para que no se reintente para siempre.

Parameters

options

RedisStreamConsumerOptions

Returns

object

stop()

stop(): Promise<void>

Returns

Promise<void>