Carrot

A synchronous amqp client. Based on Aman's amqp client:

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.

There is currently no way to prevent buffering using eventmachine. Support for prefetch is still unreliable.

Examples

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

Using options with server and queue

require 'carrot'

c = Carrot.new
q = c.queue('queue_name', {
  host: 'example.com',
  user: 'username',
  pass: 'passwd',
  vhost: '/',
  auto_delete: true
})
c.direct("name.exchange", { :durable => true })

10.times do |num|
  q.publish(num.to_s, {persistent: true, no_wait: false})
end

puts "Queued #{q.message_count} messages"

while msg = q.pop(:ack => true)
  puts "Popping: #{msg}"
  q.ack
end
c.stop

carrot

Development

Carrot

Motivation

Examples

Using options with server and queue

LICENSE