A framework for task execution written around bunny.
Usable on its own, or as part of Hopper.
channel = ::. queue = ::.("hopper-stresstest") publisher = queue.publisher(channel) publisher.publish(m)
channel = ::. queue = ::.("hopper-stresstest") listener = queue.listener(channel) listener.listen do |m| unless valid(m) m.reject next end # do some stuff m.acknowledge end
- Add support for pluggable serialization mechanisms (MsgPack, JSON, etc.)
See Contributing for details.
©2015 Ed Carrel. Released under the MIT License.
See License for details.