Message Queues & Background Jobs Packages
Task queues, job schedulers, and background-processing libraries for running work asynchronously and reliably outside the request cycle (BullMQ, Celery).
Packages in Message Queues & Background Jobs
Kind
Sort:Used by Most Apps
@golevelup/nestjs-rabbitmq
Decorator-driven RabbitMQ publish/subscribe and RPC handlers for NestJS applications
taskiq
An async-first distributed task queue for Python with type-safe tasks, pluggable brokers, and first-class FastAPI/AioHTTP integration.
rumqttc
A high-level, robust async MQTT client for Rust built on tokio.
aiokafka
An asyncio-native Kafka client for Python with high-level producer and consumer APIs.
RabbitMqBundle
Symfony bundle integrating php-amqplib for RabbitMQ producers, consumers, and console commands
Laravel Webhook Server
Configure and send signed, retryable webhooks from Laravel applications with ease.
Yii2 Queue
Run tasks asynchronously via queues in Yii 2 with pluggable backends.
tokio-cron-scheduler
Schedule async tasks on Tokio using cron-like annotations, one-shot timers, or repeating intervals.
celery-once
Prevents Celery from executing or queuing the same task more than once, using a distributed Redis or file-based lock keyed by task name and arguments.
django-q2
A multiprocessing distributed task queue for Django, with schedules, cron, and pluggable brokers.
NATS Node Transport
The official Node.js and Bun TCP transport that connects the NATS.js client to a NATS server.
pulsar-rs
A pure Rust, future-based client for Apache Pulsar with async/await, TLS, batching, and pluggable compression.
Clokwerk
Schedule recurring tasks in Rust with a readable DSL instead of cron strings.
CloudEvents
The official Python SDK for building, validating, and converting CloudEvents across HTTP, Kafka, AMQP, and RabbitMQ.
RSKafka
A minimal, dependency-light Rust client for Apache Kafka, built for using Kafka as a distributed write-ahead log.
celery-singleton
A Celery task base class that guarantees only one instance of a task runs at a time.
rabbitmq-stream-client
An async Rust client for RabbitMQ Streams with high-throughput publishing and consuming.
later
Composable library for defining recurring schedules and calculating their next or previous occurrences.
kafka-python-ng
Actively maintained Python client for the Apache Kafka stream platform
weasel
A small workflow system for orchestrating ML training, packaging, and serving pipelines
dagster-cloud
The Hybrid Agent package that connects your own infrastructure to Dagster+'s managed orchestration control plane.
scheduled-thread-pool
A Rust thread pool that runs tasks after a delay and can repeat them at fixed intervals.
s2-sdk-typescript
The official TypeScript SDK for S2's durable streams API - append, read, and tail records with typed, retryable sessions.
QStash Python SDK
Official Python SDK for Upstash QStash serverless messaging and scheduling.
