Task queue ports (TaskQueue, TaskStore, TaskWorker) with a local virtual-thread implementation. Payloads are data-only, delivery is at-least-once, cancellation is cooperative — the contract is written for the cluster path (DB store with SKIP LOCKED + lease) from day one, even though the local implementation would not need it. See agents/doc/architecture/concepts/11-task-queue.md.

Artifacts using MC Task Queue (5)
Sort by:Popular

The agent runtime's core: agent and session domain, the ports around it (chat, tools, token counting, memory strategies, repositories) and the use cases — the turn loop, prompt assembly, tool dispatch. Free of storage, HTTP, ...
Last Release on Aug 31, 2026
Postgres-backed stores for the task queue: JdbcTaskStore (SKIP LOCKED claims, leases for crash recovery) and JdbcChannelStore (store-assigned seq per channel). Plain JDBC on a DataSource — no Spring required.
Last Release on Aug 31, 2026
The task queue as a cluster: ONE jar, two roles. The master serves the dashboard, submits tasks and starts/monitors worker JVMs as OS processes; workers run the unchanged LocalTaskQueue against the shared Postgres store.
Last Release on Aug 31, 2026
Demo app for mc-task-queue: pick a task type, submit it with parameters, and watch tasks and channels live on a streaming board (semantic-ui SSE). Flagship task: crawl a website as a parent/child task tree, one page per child, ...
Last Release on Aug 31, 2026
Cron for the task queue, as an addon rather than a queue feature: a TaskSchedule is a long-lived definition in its own store, and every firing becomes an ordinary TaskSubmission. Includes a dependency-free cron parser.
Last Release on Aug 31, 2026
  • Prev
  • 1
  • Next