Type Alias ProcessorFnParams

ProcessorFnParams: {
    isStopped: () => boolean;
    message: {
        channelName: string;
        channelPriority: number | null;
        id: string;
        name: string;
        numAttempts: number;
        payload: string;
        priority: number | null;
    };
    setRetry: (params?: { lockMs?: number }) => void;
}

Type declaration

  • isStopped: () => boolean
  • message: {
        channelName: string;
        channelPriority: number | null;
        id: string;
        name: string;
        numAttempts: number;
        payload: string;
        priority: number | null;
    }
  • setRetry: (params?: { lockMs?: number }) => void