Setu-TS
    Preparing search index...

    Interface RedisStreamsOptions

    Redis-specific options (internal use).

    0.1.0

    interface RedisStreamsOptions {
        blockSizeMs?: number;
        client?: IRedisStreamsClient;
        connectionErrorReporter?: ConnectionErrorReporter;
        consumerIdleSweepMs?: number;
        consumerRetry?: ConsumerRetryOptions;
        deadLetterMaxLen?: number;
        defaultQueue?: string;
        logger?: { error: (msg: string) => void };
        pollIntervalMs?: number;
        publishTimeoutMs?: number;
        reclaimIntervalMs?: number;
        url?: string;
    }
    Index
    blockSizeMs? client? connectionErrorReporter? consumerIdleSweepMs? consumerRetry? deadLetterMaxLen? defaultQueue? logger? pollIntervalMs? publishTimeoutMs? reclaimIntervalMs? url?
    blockSizeMs?: number

    Block timeout in milliseconds.

    client?: IRedisStreamsClient

    Injected Redis client.

    connectionErrorReporter?: ConnectionErrorReporter

    Receives the connection errors (ioredis 'error' events) of the client the broker BUILDS, instead of ioredis printing each reconnect failure to the console. Never attached to an injected client, which belongs to the caller. MessagingPlugin supplies one backed by its logger.

    0.9.0

    consumerIdleSweepMs?: number

    Foreign idle-consumer sweep threshold; see RedisStreamsMessagingOptions.

    consumerRetry?: ConsumerRetryOptions

    Shared retry shape used by the Redis plugin arm.

    deadLetterMaxLen?: number

    Approximate dead-letter retention; see RedisStreamsMessagingOptions.

    defaultQueue?: string

    Default consumer group name.

    logger?: { error: (msg: string) => void }

    Optional logger for error reporting.

    pollIntervalMs?: number

    Poll interval in milliseconds.

    publishTimeoutMs?: number

    Publish acknowledgement bound in ms, from 0 through 2147483647. Zero disables the bound; an expired publish may still be delivered. Consumer reads are unaffected.

    15000

    0.11.0

    reclaimIntervalMs?: number

    Reclaim interval; see RedisStreamsMessagingOptions.

    url?: string

    Redis connection URL.

    Settings
    Member Visibility

    On This Page
    Properties