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.