export default {
async queue(batch: MessageBatch, env: Env, ctx: ExecutionContext) {
try {
await process(env, ctx);
} catch (e) {
const logger = getLogger(ctx, env.LOG_TAIL_TOKEN);
await logger.error(`Uncaught error: ${e instanceof Error ? e.stack : String(e)}`);
} finally {
batch.ackAll(); // <-- ACK ALL
}
},
...router
};
export default {
async queue(batch: MessageBatch, env: Env, ctx: ExecutionContext) {
try {
await process(env, ctx);
} catch (e) {
const logger = getLogger(ctx, env.LOG_TAIL_TOKEN);
await logger.error(`Uncaught error: ${e instanceof Error ? e.stack : String(e)}`);
} finally {
batch.ackAll(); // <-- ACK ALL
}
},
...router
};