Setu-TS
    Preparing search index...

    Interface RabbitMqQueueOptions

    Options for configuring RabbitMqQueue.

    interface RabbitMqQueueOptions {
        client?: IAmqpQueueConnection;
        persistentMessages?: boolean;
        prefix?: string;
        publishTimeoutMs?: number;
        reportWarning?: (message: string) => void;
        url?: string;
    }
    Index
    client? persistentMessages? prefix? publishTimeoutMs? reportWarning? url?
    client?: IAmqpQueueConnection

    Injected AMQP connection (bypasses lazy import).

    persistentMessages?: boolean

    Publish jobs persistent (default true). See QueuePluginOptions.persistentMessages.

    0.9.0

    prefix?: string

    Queue name prefix (default 'he.queue').

    publishTimeoutMs?: number

    Bound on one job publish, including its confirm, in ms (default 15000, 0 unbounded). See QueuePluginOptions.publishTimeoutMs.

    0.9.0

    reportWarning?: (message: string) => void

    Receives the one warning the adapter emits when the connection cannot open a confirm channel. QueuePlugin supplies one backed by its logger.

    0.9.0

    url?: string

    RabbitMQ connection URL (default 'amqp://localhost:5672').

    Settings
    Member Visibility

    On This Page
    Properties