Worker

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

const assistant = new Agent({
  name: "assistant",
  model: openai("gpt-4o"),
  instructions: "You are a helpful assistant.",
});

const worker = new AgentWorker({
  connection: { host: "localhost", port: 6379 },
  agentRegistry: { assistant },
  concurrency: 5,
});

worker.start();

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

const researcher = new Agent({
  name: "researcher",
  model: openai("gpt-4o"),
  instructions: "Research the given topic thoroughly.",
});

const writer = new Agent({
  name: "writer",
  model: openai("gpt-4o"),
  instructions: "Write a blog post based on the research.",
});

const pipeline = new Workflow({
  name: "content-pipeline",
  initialState: { topic: "", research: "", article: "" },
  steps: [
    { name: "research", agent: researcher, inputFrom: (s) => s.topic },
    { name: "write", agent: writer, inputFrom: (s) => `Write about: ${s.research}` },
  ],
});

const worker = new AgentWorker({
  connection: { host: "localhost", port: 6379 },
  agentRegistry: { researcher, writer },
  workflowRegistry: { "content-pipeline": pipeline },
  concurrency: 3,
});

worker.start();

process.on("SIGTERM", async () => {
  console.log("Shutting down worker...");
  await worker.stop();
  process.exit(0);
});

import { bridgeEventBusToJob } from "@agentium/queue";

// This is used internally by AgentWorker, but you can use it
// for custom worker implementations
const cleanup = bridgeEventBusToJob(agent.eventBus, job, runId);

// cleanup() removes all listeners when done

# Terminal 1
node worker.js

# Terminal 2
node worker.js

# Terminal 3
node worker.js

// producer.ts
import { AgentQueue } from "@agentium/queue";

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

const { jobId } = await queue.enqueueAgentRun({
  agentName: "assistant",
  input: "Summarize the latest AI research papers",
});

queue.onCompleted((id, result) => {
  console.log(`Result: ${result.text}`);
  queue.close();
});

// worker.ts
import { Agent, openai } from "@agentium/core";
import { AgentWorker } from "@agentium/queue";

const assistant = new Agent({
  name: "assistant",
  model: openai("gpt-4o"),
  instructions: "Summarize research papers concisely.",
});

const worker = new AgentWorker({
  connection: { host: "localhost", port: 6379 },
  agentRegistry: { assistant },
});

worker.start();
console.log("Worker listening for jobs...");