Skip to main content
Version: Current

RedisBroker

@rotorsoft/act-root

@rotorsoft/act-root / act-notify / RedisBroker

Class: RedisBroker

Defined in: libs/act-notify/src/redis.ts:43

Fan-out over redis pub/sub. Malformed payloads on the channel are dropped with a warning — the channel is a hint path, so garbage degrades latency for one wakeup, never correctness.

Implements​

Constructors​

Constructor​

new RedisBroker(options): RedisBroker

Defined in: libs/act-notify/src/redis.ts:48

Parameters​

options​

RedisBrokerOptions

Returns​

RedisBroker

Methods​

publish()​

publish(message): Promise<void>

Defined in: libs/act-notify/src/redis.ts:54

Parameters​

message​

BrokerMessage

Returns​

Promise<void>

Implementation of​

Broker.publish

subscribe()​

subscribe(handler): Promise<BrokerDisposer>

Defined in: libs/act-notify/src/redis.ts:58

Parameters​

handler​

(message) => void

Returns​

Promise<BrokerDisposer>

Implementation of​

Broker.subscribe