Skip to content

RedisStreamsActor

Defined in: src/io/broker/RedisStreamsActor.ts:56

Redis-Streams actor. Wraps ioredis (already a peer-dep used by the cache layer). Producer + optional consumer in one actor.

Consumer mode uses XREADGROUP with a stable consumer name; entries are delivered to target and are NOT auto-acked — the caller must tell({ kind: 'ack', stream, id }) after processing for at-least- once semantics with crash-recovery. For at-most-once, ack immediately on delivery.

new RedisStreamsActor(settings?): RedisStreamsActor

Defined in: src/io/broker/RedisStreamsActor.ts:62

Partial<RedisStreamsActorSettings> = {}

RedisStreamsActor

BrokerActor<RedisStreamsActorSettings, RedisStreamsCmd, RedisStreamPublish>.constructor

onReceive(cmd): void

Defined in: src/io/broker/RedisStreamsActor.ts:129

Main message handler. Receives each envelope dequeued from the mailbox. A thrown error (sync or async) is caught by the supervisor.

RedisStreamsCmd

void

BrokerActor.onReceive


postRestart(_reason): void | Promise<void>

Defined in: src/Actor.ts:55

Called on the fresh instance after a restart. Default: call preStart().

Error

void | Promise<void>

BrokerActor.postRestart


postStop(): Promise<void>

Defined in: src/io/broker/BrokerActor.ts:241

Called after the actor has been terminated. Children are already stopped.

Promise<void>

BrokerActor.postStop


preRestart(_reason, _message?): void | Promise<void>

Defined in: src/Actor.ts:50

Called before a restart, on the instance about to be thrown away. The default stops children and then calls postStop().

Error

RedisStreamsCmd

void | Promise<void>

BrokerActor.preRestart


preStart(): Promise<void>

Defined in: src/io/broker/BrokerActor.ts:235

Called after construction and before the first message is processed.

Promise<void>

BrokerActor.preStart


supervisorStrategy(): SupervisorStrategy

Defined in: src/Actor.ts:63

Supervisor strategy for this actor’s children. Defaults to restart, up to 10 times per minute, then stop.

SupervisorStrategy

BrokerActor.supervisorStrategy