Build Status Dependency Status Coverage Status Code Climate Gem Version License Badges

Hopper

A framework for task execution written around bunny.

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

©2015 Ed Carrel. Released under the MIT License.

See License for details.