Displaying 1 to 16 from 16 results

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.

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..

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 ...

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.




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.

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.

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.

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

  •    Javascript

A simple wrapper around the AWS SQS queue service


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.

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.

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.

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.

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.