workq - Job server in Go

•    Go

---

Workq is a job scheduling server strictly focused on simplifying job processing and streamlining coordination. It can run jobs in blocking foreground or non-blocking background mode. Workq runs as a standalone TCP server and implements a simple, text based protocol. Clients interact with Workq over a TCP socket in a request/response model with text commands. Please refer to the full protocol doc for details.

queue queueing jobs jobqueue job job-scheduler worker workers scheduler schedule

node-nats - Node.js client for NATS, the cloud native messaging system.

•    Javascript

---

A Node.js client for the NATS messaging system.See examples and benchmarks for more information..

nats messaging pubsub publish subscribe queue distributed queueing

hemera - 🔬 Writing reliable & fault-tolerant microservices with https://nats.io

•    Javascript

---

Hemera (/ˈhɛmərə/; Ancient Greek: Ἡμέρα [hɛːméra] "day") is a small wrapper around the NATS driver. NATS is a simple, fast and reliable solution for the internal communication of a distributed system. It chooses simplicity and reliability over guaranteed delivery. We want to provide a toolkit to develop micro services in an easy and powerful way. We provide a pattern matching RPC style. You don't have to worry about the transport. NATS is powerful.Hemera has not been designed for high performance on a single process. It has been designed to create lots of microservices doesn't matter where they live. It choose simplicity and reliability as primary goals. It act together with NATS as central nervous system of your distributed system. Transport independency was not considered to be a relevant factor. In addition we use pattern matching which is very powerful. The fact that Hemera needs a broker is an argument which should be taken into consideration when you compare hemera with other frameworks. The relevant difference between microservice frameworks like senecajs, molecurer is not the performance or modularity its about the complexity you need to manage. Hemera is expert in providing an interface to work with lots of services in the network, NATS is the expert to deliver the message at the right place. Hemera is still a subscriber of NATS with some magic in routing and extensions. We don't have to worry about all different aspects in a distributed system like routing, load-balancing, service-discovery, clustering, health-checks ...

nodejs distributed-systems microservice nats pubsub rpc cloud-native micro service micro-service microservices micro-services services framework minimum viable product toolkit startup messaging publish subscribe queue distributed queueing

kq - Kafka-based Job Queue for Python

•    Python

---

KQ (Kafka Queue) is a lightweight Python library which lets you queue and execute jobs asynchronously using Apache Kafka. It uses kafka-python under the hood. You may need to use sudo depending on your environment.

kafka job-queue async kafka-client kafka-consumer kafka-producer python3 python2 python-library python-3 python-2 asynchronous queueing jobqueue apache-kafka worker-queue producer-consumer serialization python-3-5

swarrot - A lib to consume message from any Broker

•    PHP

---

Swarrot is a PHP library to consume messages from any broker. Heavily inspired by stackphp/builder you can use Swarrot\Processor\Stack\Builder to stack your processors. Using the built in processors or by creating your own, you can extend the behavior of your base processor. In this example, your processor is decorated by 2 other processors. The ExceptionCatcherProcessor which decorates your own with a try/catch block and the MaxMessagesProcessor which stops your worker when some messages have been consumed.

swarrot rabbitmq rabbit sqs queue queueing

node-nats-streaming - Node.js client for NATS Streaming

•    Javascript

---

Node NATS Streaming is an extremely performant, lightweight reliable streaming platform powered by NATS for Node.js.NATS Streaming subscriptions are similar to NATS subscriptions, but clients may start their subscription at an earlier point in the message stream, allowing them to receive messages that were published before this client registered interest.

nats streaming messaging pubsub publish subscribe queue distributed queueing

ost - Redis based queues and workers.

•    Ruby

---

Redis based queues and workers.Ost makes it easy to enqueue object ids and process them with workers.

workers queueing lesscode job-queue task-queue queue worker background-task

simple-sqs - A simple wrapper around the AWS SQS queue service

•    Javascript

---

A simple wrapper around the AWS SQS queue service

sqs queue queueing aws

libqueue - C library providing persistent, named data storage queues w/ CLI utils. Uses LevelDB.

•    C

---

libqueue is a C library that provides persistent, named data queues for programs. Arbitrarily many queues can co-exist, given they have distinct names. The data itself is stored using leveldb in a compressed hash tree.

database leveldb library queueing

amqp-replay - :video_camera: Replay messages from (RabbitMQ) AMQP dead-letter queue

•    Javascript

---

Add INFINITE=true to replay the queue message infinitely. See LICENSE.

amqp-replay amqp rabbitmq replay-messages dead-letter queue queueing replay

toro - Multithreaded message processing on Postgres

•    Ruby

---

Multithreaded message processing on Postgres

message-queue queue queueing postgres postgresql background-jobs workers

qure.js - Javascript library facilitating asynchronous programming

•    Javascript

---

It is also possible to "fork" the timeline...which enables multiple queueing/chaining, independent of each other.

concurrency queueing recursion design-pattern

PSRabbitMq - PowerShell module to send and receive messages from a RabbitMq server

•    PowerShell

---

PowerShell module to send and receive messages from a RabbitMQ server. All credit to @gpduck, all blame for butchering to @ramblingcookiemonster.

powershell powershell-modules rabbitmq rabbitmq-server message-bus message queue queueing amqp

ts-nats - TypeScript Node.js client for NATS, the cloud native messaging system

•    TypeScript

---

A TypeScript Node.js client for the NATS messaging system. ts-nats is a typescript nats library for node that supports Promises and async/await patterns. Full documentation.

nats messaging pubsub publish subscribe queue distributed queueing

RXBus - RX based bus with lifecycle based queuing support

•    Java

---

RX based bus with lifecycle based queuing support

rxjava bus eventbus queueing

RxBus2 - RxJava2 based bus with queuing (e.g. lifecycle based) support

•    Java

---

This is an reactive implementation of an event bus, with a few convenient functions especially useful for handling events with activities, fragments and similar.

rxjava2 bus eventbus queueing