Sha256: b0ef58f503c90c51e066c9153c3f40416c3f1bac450b29aca25c9c1839722659
Contents?: true
Size: 1021 Bytes
Versions: 10
Compression:
Stored size: 1021 Bytes
Contents
# Carrot
A synchronous amqp client. Based on Aman's amqp client:
[http://github.com/tmm1/amqp/tree/master] (http://github.com/tmm1/amqp/tree/master)
## Motivation
This client does not use eventmachine so no background thread necessary. As a result, it is much easier to use from script/console and Passenger. It also solves the problem of buffering messages and ack responses. For more details see [this thread] (http://groups.google.com/group/ruby-amqp/browse_thread/thread/fdae324a0ebb1961/fa185fdce1841b68).
There is currently no way to prevent buffering using eventmachine. Support for prefetch is still unreliable.
## Example
require 'carrot'
q = Carrot.queue('name')
10.times do |num|
q.publish(num.to_s)
end
puts "Queued #{q.message_count} messages"
puts
while msg = q.pop(:ack => true)
puts "Popping: #{msg}"
q.ack
end
Carrot.stop
# LICENSE
Copyright (c) 2009 Amos Elliston, Geni.com; Published under The MIT License, see License
Version data entries
10 entries across 10 versions & 6 rubygems