RedisSubscriberClient
interfaz
Conexión suscriptora dedicada, compatible por estructura con node-redis 4 o posterior, que exige
un cliente aparte en modo suscriptor (por ejemplo, client.duplicate()).
ts
import type { RedisSubscriberClient } from "@meekojs/meeko/server";Código fuente src/server/runtime/redis-pubsub.ts:52
Declaración #
ts
interface RedisSubscriberClient {
subscribe(channel: string, listener: RedisMessageListener): Promise<unknown>
unsubscribe(channel: string, listener: RedisMessageListener): Promise<unknown>
sSubscribe?(channel: string, listener: RedisMessageListener): Promise<unknown>
sUnsubscribe?(channel: string, listener: RedisMessageListener): Promise<unknown>
}Ejemplo #
ts
import { createClient } from "redis";
import type { RedisSubscriberClient } from "@meekojs/meeko/server";
const redis = createClient({ url: process.env.MEEKO_REDIS_URL });
const connection = redis.duplicate();
await connection.connect();
const subscriber: RedisSubscriberClient = connection;Miembros #
subscribe
#
subscribe(channel: string, listener: RedisMessageListener): Promise<unknown>SUBSCRIBE a un canal con un listener.
unsubscribe
#
unsubscribe(channel: string, listener: RedisMessageListener): Promise<unknown>UNSUBSCRIBE de ese listener.
sSubscribe
#
sSubscribe?(channel: string, listener: RedisMessageListener): Promise<unknown>Pub/sub fragmentado de Redis 7 (SSUBSCRIBE); sólo hace falta con sharded: true.
sUnsubscribe
#
sUnsubscribe?(channel: string, listener: RedisMessageListener): Promise<unknown>SUNSUBSCRIBE; sólo hace falta con sharded: true.