Skein

Skein is a RabbitMQ-based method for handling remote procedure calls (RPC) and pub/sub channels over AMQP using JSON-RPC payloads.

This library requires an active AMQP server like RabbitMQ and a Ruby driver for AMQP like Bunny or March Hare.

Both JRuby and MRI Ruby are supported with the appropriate driver.

The default Bundler configuration should be a good place to start:

bundle install

For testing, set up config/rabbitmq.yml with configuration parameters that define how to connect to RabbitMQ.

An RPC client can make blocking or non-blocking calls. By default calls are blocking, but they can be made non-blocking by adding ! to the end of the method name. For example:

client = Skein::Client.rpc('test_queue')

client.request!(test: 'data')

client.close

Note that non-blocking calls are fire-and-forget, there is no way of knowing if that operation succeeded or failed.

The back-end that receives and processes RPC calls is instantiated as a Skein::Client::Worker instance:

class Responder < Skein::Client::Worker
  def request
    {
      result: true
    }
  end
end

Responder.new('test_queue')

Setting the environment variable SKEIN_DEBUG_JSON will show raw JSON payloads received by both RPC workers and clients.