lonnymq
    Preparing search index...

    Interface QueueChannelPolicyModule<T>

    interface QueueChannelPolicyModule<T> {
        clear(params: { databaseClient: T }): Promise<void>;
        set(
            params: {
                databaseClient: T;
                maxConcurrency?: null | number;
                maxSize?: null | number;
                releaseIntervalMs?: null | number;
            },
        ): Promise<void>;
    }

    Type Parameters

    • T
    Index

    Methods

    Methods

    • Parameters

      • params: {
            databaseClient: T;
            maxConcurrency?: null | number;
            maxSize?: null | number;
            releaseIntervalMs?: null | number;
        }

      Returns Promise<void>