Hopper
A framework for task execution written around bunny.
Usable on its own, or as part of Baler.
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
endTODO
- 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.