Interface ConsumerMessages

interface ConsumerMessages {
    [asyncIterator](): AsyncIterator<JsMsg, any, undefined>;
    close(): Promise<void | Error>;
    closed(): Promise<void | Error>;
    getPending(): number;
    getProcessed(): number;
    getReceived(): number;
    push(v): void;
    status(): Promise<AsyncIterable<ConsumerStatus>>;
    stop(err?): void;
}

Hierarchy (view full)

Methods

[asyncIterator] close closed getPending getProcessed getReceived push status stop

Methods

[asyncIterator]

close

  • close(): Promise<void | Error>

  • Returns Promise<void | Error>

closed

  • closed(): Promise<void | Error>

  • Returns Promise<void | Error>

getPending

getProcessed

getReceived

push

  • push(v): void

  • Parameters

    Returns void

status

stop

  • stop(err?): void

  • Parameters

    • Optional err: Error

    Returns void

Settings

Member Visibility

Theme

On This Page

[asyncIterator]closeclosedgetPendinggetProcessedgetReceivedpushstatusstop