Sha256: 53aaae043d0607f1359dbf5910bd69e3ff5beb5b693f45e6371f415447b80c7d

Contents?: true

Size: 956 Bytes

Versions: 124

Compression:

Stored size: 956 Bytes

Contents

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

require "rubygems"
require "bunny"

puts "=> Demonstrating sender-selected distribution"
puts

conn = Bunny.new
conn.start

ch   = conn.create_channel
x    = ch.direct("bunny.examples.ssd.exchange")
q1   = ch.queue("", :exclusive => true).bind(x, :routing_key => "one")
q2   = ch.queue("", :exclusive => true).bind(x, :routing_key => "two")
q3   = ch.queue("", :exclusive => true).bind(x, :routing_key => "three")
q4   = ch.queue("", :exclusive => true).bind(x, :routing_key => "four")

10.times do |i|
  x.publish("Message #{i}", :routing_key => "one", :headers => {"CC" => ["two", "three"]})
end

sleep 0.2
puts "Queue #{q1.name} now has #{q1.message_count} messages in it"
puts "Queue #{q2.name} now has #{q2.message_count} messages in it"
puts "Queue #{q3.name} now has #{q3.message_count} messages in it"
puts "Queue #{q4.name} now has #{q4.message_count} messages in it"

sleep 0.7
puts "Closing..."
conn.close

Version data entries

124 entries across 124 versions & 1 rubygems

Version Path
bunny-2.17.0 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.16.1 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.15.0 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.14.4 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.14.3 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.14.2 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.14.1 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.13.0 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.12.1 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.12.0 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.12.0.rc1 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.11.0 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.11.0.pre1 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.10.0 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.9.2 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.9.1 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.6.7 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.7.4 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.8.1 examples/guides/extensions/sender_selected_distribution.rb
bunny-2.9.0 examples/guides/extensions/sender_selected_distribution.rb