Contents

#!/usr/bin/env ruby
# encoding: utf-8

require "rubygems"
require "bunny"

puts "=> Demonstrating basic.nack"
puts

conn = Bunny.new
conn.start

ch   = conn.create_channel
q    = ch.queue("", :exclusive => true)

20.times do
  q.publish("")
end

20.times do
  delivery_info, _, _ = q.pop(:ack => true)

  if delivery_info.delivery_tag == 20
    # requeue them all at once with basic.nack
    ch.nack(delivery_info.delivery_tag, true, true)
  end
end

puts "Queue #{q.name} still has #{q.message_count} messages in it"

sleep 0.7
puts "Disconnecting..."
conn.close

Version data entries

66 entries across 66 versions & 1 rubygems

Version	Path
bunny-0.9.0.pre10	examples/guides/extensions/basic_nack.rb
bunny-0.9.0.pre9	examples/guides/extensions/basic_nack.rb
bunny-0.9.0.pre8	examples/guides/extensions/basic_nack.rb
bunny-0.9.0.pre7	examples/guides/extensions/basic_nack.rb
bunny-0.9.0.pre6	examples/guides/extensions/basic_nack.rb
bunny-0.9.0.pre5	examples/guides/extensions/basic_nack.rb