MQueue

A client for Sparrow http://code.google.com/p/sparrow/

Example

class MyQueue < MQueue::Queue def on_message(args) puts "Received msg with args: #argsargs.inspect" end end

servers = [ MQueue::Protocols::Sparrow.new(=> 'localhost', :port => 11212, :weight => 1) ]

MyQueue.servers = servers MyQueue.publish 'test' MyQueue.run

Copyright (c) 2008 Alex MacCaw, released under the MIT license