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 scheduleA Node.js client for the NATS messaging system. The json connect property makes it easier to exchange JSON data with other clients.
nats messaging pubsub publish subscribe queue distributed queueingA Node.js client for the NATS messaging system.See examples and benchmarks for more information..
nats messaging pubsub publish subscribe queue distributed queueingHemera (/ˈ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 queueingKQ (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-5Swarrot 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 queueingNode 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 queueingRedis 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-taskA simple wrapper around the AWS SQS queue service
sqs queue queueing awslibqueue 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 queueingAdd INFINITE=true to replay the queue message infinitely. See LICENSE.
amqp-replay amqp rabbitmq replay-messages dead-letter queue queueing replayMultithreaded message processing on Postgres
message-queue queue queueing postgres postgresql background-jobs workersIt is also possible to "fork" the timeline...which enables multiple queueing/chaining, independent of each other.
concurrency queueing recursion design-patternPowerShell 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 amqpA 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 queueingRX based bus with lifecycle based queuing support
rxjava bus eventbus queueingThis 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 queueingA 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 queueingNATS Streaming Server is an extremely performant, lightweight reliable streaming platform powered by NATS. 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 queueingThis is a Queue system for CakePHP 4. The plugin consists of a CakePHP shell wrapper and Queueing libraries for the php-queue queue library.
queue cakephp queueing cakephp-plugin queue-interop
We have large collection of open source products. Follow the tags from
Tag Cloud >>
Open source products are scattered around the web. Please provide information
about the open source projects you own / you use.
Add Projects.