Interface SubscribeOptions

Options for queue declaration and channel settings used by AMQPSession.subscribe.

interface SubscribeOptions {
    prefetch?: number;
    queue?: QueueParams;
    queueArgs?: Record<string, unknown>;
}

Properties

prefetch?: number

Per-consumer prefetch limit.

Queue declaration params for (re-)declaring on each reconnect. Omit for passive declare.

queueArgs?: Record<string, unknown>

Extra queue declare arguments — only used when queue is also provided.