Skip to main content
Version: Next

RedisPubSubDriver

RedisPubSubDriver​

@commandkit/queueindex.ts
Signature
class RedisPubSubDriver<TEvent extends Record<string, any> = Record<string, any>> implements MessageQueue {
    constructor(broker: PubSubRedisBroker<TEvent>)
    send(topic: T, message: TEvent[T]) => Promise<void>;
    receive(topic: T, handler: Handler<TEvent>) => Promise<void>;
    close() => Promise<void>;
}

constructor​

method
(broker: PubSubRedisBroker<TEvent>) => RedisPubSubDriver

send​

method
(topic: T, message: TEvent[T]) => Promise<void>

receive​

method
(topic: T, handler: Handler<TEvent>) => Promise<void>

close​

method
() => Promise<void>