Displaying 1 to 20 from 97 results

flower - Real-time monitor and web admin for Celery distributed task queue

  •    Python

Flower is a web based tool for monitoring and administrating Celery clusters. Flower API enables to manage the cluster via REST API, call tasks and receive task events in real-time via WebSockets.

yii2-queue - Yii2 Queue Extension. Supports DB, Redis, RabbitMQ, Beanstalk and Gearman

  •    PHP

An extension for running tasks asynchronously via queues. It supports queues based on DB, Redis, RabbitMQ, AMQP, Beanstalk and Gearman.




enqueue-dev - PHP7.1+. Message queue packages for PHP, Symfony, Laravel, Yii, and Magento

  •    PHP

Enqueue is production ready, battle-tested messaging solution for PHP. Provides a common way for programs to create, send, read messages. This is a main development repository. It provides a friendly environment for productive development and testing of all Enqueue related features&packages.

php-amqplib - The most widely used PHP client for RabbitMQ

  •    PHP

This library is a pure PHP implementation of the AMQP 0-9-1 protocol. It's been tested against RabbitMQ. Requirements: PHP 5.3 due to the use of namespaces.

Transporter - Sync data between persistence engines, like ETL only not stodgy

  •    Go

Compose Transporter helps with database transformations from one store to another. It can also sync from one to another or several stores.Transporter allows the user to configure a number of data adaptors as sources or sinks. These can be databases, files or other resources. Data is read from the sources, converted into a message format, and then send down to the sink where the message is converted into a writable format for its destination. The user can also create data transformations in JavaScript which can sit between the source and sink and manipulate or filter the message flow.

Dramatiq - Simple distributed task processing for Python 3.

  •    Python

dramatiq is a distributed task processing library for Python with a focus on simplicity, reliability and performance.


chef-cookbook - Development repository for Chef cookbook RabbitMQ

  •    Ruby

This is a cookbook for managing RabbitMQ with Chef. It is intended for RabbitMQ 3.5.8 or later releases and targets Chef 12.1 and later.This cookbook depends on the Erlang cookbook.

rabbitmq-delayed-message-exchange - Delayed Messaging for RabbitMQ

  •    Erlang

This plugin adds delayed-messaging (or scheduled-messaging) to RabbitMQ.A user can declare an exchange with the type x-delayed-message and then publish messages with the custom header x-delay expressing in milliseconds a delay time for the message. The message will be delivered to the respective queues after x-delay milliseconds.

watermill - Building event-driven applications easy way in Go.

  •    Go

Watermill is a Go library for working efficiently with message streams. It is intended for building event driven applications, enabling event sourcing, RPC over messages, sagas and basically whatever else comes to your mind. You can use conventional pub/sub implementations like Kafka or RabbitMQ, but also HTTP or MySQL binlog if that fits your use case. Note: Watermill should run reliably in a production environment, but it is still under heavy development and the public API may change before the 1.0.0 release.

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.

nomad-firehose - Firehose all nomad job, allocation, nodes and evaluations changes to rabbitmq, kinesis or stdout

  •    Go

nomad-firehose is a tool meant to enable teams to quickly build logic around nomad task events without hooking into Nomad API.The project got build artifacts for linux, darwin and windows in the GitHub releases tab.

rabbus - A tiny wrapper over amqp exchanges and queues 🚌 ✨

  •    Go

The rabbus package exposes a interface for emitting and listening RabbitMQ messages.

rabbitmq-mqtt - RabbitMQ MQTT plugin

  •    Erlang

This is an MQTT plugin for RabbitMQ.Default port used by the plugin is 1883.

rabbitmq-peer-discovery-k8s - Kubernetes-based peer discovery backend for RabbitMQ 3.7.0+

  •    Erlang

This is an K8s-based implementation of RabbitMQ peer discovery interface (new in 3.7.0, previously available in the rabbitmq-autocluster plugin by Gavin Roy).This plugin only performs peer discovery using Kubernetes API as a data source. Please get familiar with RabbitMQ clustering fundamentals before attempting to use it.

rabbitmq-sharding

  •    Erlang

This plugin introduces the concept of sharded queues for RabbitMQ. Sharding is performed by exchanges, that is, messages will be partitioned across "shard" queues by one exchange that we should define as sharded. The machinery used behind the scenes implies defining an exchange that will partition, or shard messages across queues. The partitioning will be done automatically for you, i.e: once you define an exchange as sharded, then the supporting queues will be automatically created on every cluster node and messages will be sharded across them.This plugin is reasonably mature and known to have production users.

rabbitmq-top - Adds top-like information on the Erlang VM to the management plugin.

  •    Erlang

Adds UNIX top-like information on the Erlang VM to the management plugin.You can download a pre-built binary of this plugin for RabbitMQ 3.5.x from RabbitMQ Community plugins page.

rabbitmq-trust-store - A trust store whitelists x509 certificates

  •    Erlang

This plugin provides support for TLS (x509) certificate whitelisting. All plugins which use the global TLS options will be configured with the same whitelist.RabbitMQ can be configured to accepted self-signed certificates through various TLS socket options, namely the ca_certs and partial_chain properties. However, this configuration is largely static. There is no convenient means with which to change it in realtime, that is, without making configuration changes to TLS listening sockets.