Lightweight, opinionated wrapper for using RabbitMQ headers exchanges

Command line tools for processing messages by constructing a pipeline of workers. AMQP and Unix pipes are used to construct the pipeline. Messages are simple Hashes (serialized as YAML) so they can hold any values and change throughout the processing.

A friendly way to talk to RabbitMQ

QueueingRabbit is a Ruby library providing a flexible DSL to interact with a RabbitMQ server. Any Ruby class or Module can be transformed into QueueingRabbit's background job by including QueueingRabbit::Job module. It is also possible to inherit your class from QueueingRabbit::AbstractJob abstract class. The library is bundled with a Rake task to start a worker processing a list of specified jobs.

A background task based on rake to consume RabbitMQ messages

A gem providing asynchronous event publish and subscribe capabilities with RabbitMQ.

Background jobs on RabbitMQ

Rabbit (Rabbit Messaging)

Provides a generic Rapids/Rivers framework, and a specific implementation using RabbitMQ as the event bus.

A drop-in replacement for Graphite Carbon (TCP & AMQP), sending metrics to Librato Metrics.

This gem is used to communicate to a server Janus through RabbitMQ software (Message-oriented middleware). It waiting a messages to Rails API who send to RabbitMQ server in a queue for janus server. Janus processes a message and send to RabbitMQ server in a queue for gem. Once the received message is decoded and returned through the Rails API.

Sevak lets you easily add consumers in your rails app

Publish and subscribe rabbitMQ messages

AMQP hook for Delayed Job, backed by ActiveRecord

Provides the Publisher part of the Untied gem.

Abstract flow publisher and subscriber

An AMQP-based background worker system for Ruby designed to make managing heterogenous tasks relatively easy. The use case for Woodhouse is for reliable and sane performance in situations where jobs on a single queue may vary significantly in length. The goal is to permit large numbers of quick jobs to be serviced even when many slow jobs are in the queue. A secondary goal is to provide a sane way for jobs on a given queue to be given special priority or dispatched to a server more suited to them. Clients (i.e., your application) may be using either Ruby 1.9 in any VM.

A RabbitMQ subscriber that pushes messages to Acception's API. See README for more details.

Listens to RabbitMQ and spams Slack.

Action server