Skip to main content
Version: Next

MessageQueue

MessageQueue​

@commandkit/queuedriver.ts
Signature
interface MessageQueue {
    send(topic: string, message: any): Promise<void>;
    receive(
    topic: string,
    handler: (message: any) => Awaitable<void>,
  ): Promise<void>;
    close?(): Promise<void>;
}

send​

method
(topic: string, message: any) => Promise<void>

receive​

method
(topic: string, handler: (message: any) => Awaitable<void>) => Promise<void>

close​

method
() => Promise<void>