Hopper

A framework for task execution written around bunny.

Usable on its own, or as part of Hopper.

Examples

A Publisher:

  channel = Hopper::Channel.new

  queue = Hopper::Queue.new("hopper-stresstest")

  publisher = queue.publisher(channel)

  publisher.publish(m)

A Listener:

 channel = Hopper::Channel.new

 queue = Hopper::Queue.new("hopper-stresstest")

 listener = queue.listener(channel)

 listener.listen do |m|

  unless valid(m)
    m.reject
    next
  end

  # do some stuff

  m.acknowledge
end

TODO

Add support for pluggable serialization mechanisms (MsgPack, JSON, etc.)

API Documentation

See RubyDoc

Contributors

See Contributing for details.

License

See License for details.