Porcupine

Porcupine is a JRuby wrapper for Netflix's Hystrix library. It simplifies instantiating HystrixCommands and throws Ruby exceptions for most things that can go wrong (execution failures, timeouts, short circuits, no threads in the thread pool).

Add this line to your application's Gemfile:

gem 'porcupine'

And then execute:

$ bundle

Or install it yourself as:

$ gem install porcupine

Instantiate a Porcupine object and give it a name, a group name (optional), a timeout (optional) and a block:

porcupine = Porcupine.new("Sleeping Beauty", "Disney Characters", 10_000) { sleep(50) }

You can also provide a Setter directly:

setter = com.netflix.hystrix.HystrixCommand::Setter.withGroupKey(com.netflix.hystrix.HystrixCommandGroupKey::Factory.asKey("Disney Characters"))
                                                   .andCommandKey(com.netflix.hystrix.HystrixCommandKey::Factory.asKey("Sleeping Beauty"))
porcupine = Porcupine.new(setter) { sleep(50) }

Then either you can request a result immediately:

porcupine.execute

Or retrieve a Future and get the result later:

future = porcupine.queue
future.get # Blocks on the result

Subscribing to an event is also supported:

observer = porcupine.observe
observer.subscribe { puts "done!" } # Will puts "done!" when finished

If you provide an onError function, then the function will receive exceptions raised:

observer = porcupine.observe
on_next  = lambda {|val| puts "All good: #{val}"}
on_error = lambda {|exception| puts "Uh oh: #{exception}"}
observer.subscribe(on_next, on_error)

1. Fork it
2. Create your feature branch (git checkout -b my-new-feature)
3. Commit your changes (git commit -am 'Add some feature')
4. Push to the branch (git push origin my-new-feature)
5. Create new Pull Request