npm install @agentium/queue

import { Agent, openai } from "@agentium/core";
import { AgentQueue, AgentWorker } from "@agentium/queue";

const reportAgent = new Agent({
  name: "report-gen",
  model: openai("gpt-4o"),
  instructions: "You write short reports with headings.",
});

const queue = new AgentQueue({
  connection: { host: "localhost", port: 6379 },
});

const { jobId } = await queue.enqueueAgentRun({
  agentName: "report-gen",
  input: "Q4 engineering report.",
  priority: 1,
  attempts: 3,
});

const worker = new AgentWorker({
  connection: { host: "localhost", port: 6379 },
  concurrency: 3,
  agentRegistry: { "report-gen": reportAgent },
});

worker.start();

queue.onCompleted((id, result) => {
  console.log(id, result.text.slice(0, 200));
});