.destroy()
→ Promise<void>
await redisBroker.destroy();Class
RedisBroker
Constructor
new RedisBroker(options: RedisBrokerOptions)- options
RedisBrokerOptions
Methods
.publish(channel, message)
channel: string, message: unknown → Promise<void>
await redisBroker.publish(channel, message);.subscribe(channel, listener)
channel: string, listener: (message: unknown) => void → Promise<() => void>
await redisBroker.subscribe(channel, listener);