Skip to content

Messages Cleanup

Christopher Case requested to merge message-cleanup into master

Added basic cleanup to messages; we currently have the option to either delete messages when we ack them (disabled by default) or to set a limit on the queue size (unlimited by default).

New configuration:

export interface StrataServiceOptions {
    redis : RedisOptions;
    logging ?: LoggerConfig;
    service ?: {
        id ?: string,
        name ?: string;
        concurrency ?: number;

        // This replaces `queuePrefixes`
        queues ?: {
            prefixes ?: {
                request ?: string;
                response ?: string;
            },
            trimWait ?: number;
            maxTrimWait ?: number;
            maxLength ?: number;
            deleteOnAck ?: boolean;
        }
    };
    services ?: {
        [ serviceName : string ] : string;
    };

    // Also support arbitrary keys
    [ key : string ] : unknown;
}

Merge request reports