lonnymq
    Preparing search index...

    Interface QueueMessage<T>

    interface QueueMessage<T> {
        channelId: string;
        content: Buffer;
        id: bigint;
        isUnlocked: boolean;
        numAttempts: number;
        state: null | Buffer<ArrayBufferLike>;
        defer(
            params: {
                databaseClient: T;
                dequeueAt?: number;
                state?: Buffer<ArrayBufferLike>;
            },
        ): Promise<MessageDeferCommandResult>;
        delete(params: { databaseClient: T }): Promise<MessageDeleteCommandResult>;
        heartbeat(
            params: { databaseClient: T; lockMs: number },
        ): Promise<MessageHeartbeatCommandResult>;
    }

    Type Parameters

    • T
    Index

    Properties

    channelId content id isUnlocked numAttempts state

    Methods

    defer delete heartbeat

    Properties

    channelId: string

    Readonlycontent

    content: Buffer
    id: bigint
    isUnlocked: boolean
    numAttempts: number
    state: null | Buffer<ArrayBufferLike>

    Methods

    Settings

    Member Visibility

    On This Page

    Properties
    Methods