fluffle

An implementation of JSON-RPC over RabbitMQ through the Bunny library. Provides both a client and server.

A group of baby bunnies is called a fluffle.

Features

Both the client and server implementations should be thread-safe, as their behavior is implemented on top of the excellent concurrent-ruby gem's data structures.

Client: Thread-safe client that can perform multiple requests concurrently
Server: Single or multi-threaded server (one request/response per thread)
Server: Easy-to-use built-in handlers and straightforward API for building custom handlers

Examples

See the examples directory.

The server provides a few options for handling RPC requests:

Dispatcher: dispatcher.handle('upcase') { |str| str.upcase }
Delegator: delegate will receive the #upcase message with a single argument (the string)
Custom: any handler needs to implement the API described in Fluffle::Handlers::Base

Basic server and client

A server has two basic requirements: the URL of a RabbitMQ server to connect to and one or more queues to drain (with a handler for each queue).

Below is a basic server providing an upcase method to return the upper cased version of its argument:

require 'fluffle'

server = Fluffle::Server.new url: 'amqp://localhost'

server.drain do |dispatcher|
  dispatcher.handle('upcase') { |str| str.upcase }
end

server.start

This example relies on a couple features of Server#drain:

By default it will drain the default queue.
You can provide a block to the method to have it set up a Dispatcher handler and pass that in to the block.

And client to call that upcase method looks like:

client = Fluffle::Client.new url: 'amqp://localhost'

client.call 'upcase', ['Hello world!']
# => "HELLO WORLD!"

License

Released under the MIT license, see LICENSE for details.