Interface Consumer

interface Consumer {
    consume(opts?: ConsumeOptions): Promise<ConsumerMessages>;
    delete(): Promise<boolean>;
    fetch(opts?: FetchOptions): Promise<ConsumerMessages>;
    info(cached?: boolean): Promise<ConsumerInfo>;
    next(opts?: NextOptions): Promise<JsMsg>;
}

Hierarchy

  • ExportedConsumer
    • Consumer

Methods

consume delete fetch info next

Methods

consume

delete

  • delete(): Promise<boolean>

  • Returns Promise<boolean>

fetch

info

  • info(cached?): Promise<ConsumerInfo>

  • Parameters

    • Optionalcached: boolean

    Returns Promise<ConsumerInfo>

next

  • next(opts?): Promise<JsMsg>

  • Parameters

    Returns Promise<JsMsg>

Settings

Member Visibility

On This Page

Methods