Queue Dashboard

1import { createApp, queue, QueueController } from "canxjs";
2
3const app = createApp({ port: 3000 });
4
5// Mount the Queue Dashboard at /canx-queue
6app.routes((router) => {
7  router.controller('/canx-queue', QueueController);
8});
9
10app.listen();

1import { queue } from "canxjs";
2
3// Dispatch a job to the queue
4await queue.dispatch("send-email", {
5  to: "user@example.com",
6  subject: "Welcome!",
7  body: "Thank you for signing up."
8});
9
10// Dispatch with delay (5 minutes)
11await queue.schedule("send-reminder", { userId: 123 }, 300);
12
13// Process jobs
14queue.define("send-email", async (data) => {
15  await sendEmail(data);
16  console.log(`Email sent to ${data.to}`);
17});

1// Get queue statistics
2const stats = await queue.getStats();
3console.log(stats);
4// { pending: 12, failed: 2, processed: 158 }
5
6// Get failed jobs
7const failedJobs = await queue.getFailed();
8
9// Retry a specific job
10await queue.retry(jobId);
11
12// Clear all jobs
13await queue.clear();