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