Contents

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

require "bundler"
Bundler.setup

$:.unshift(File.expand_path("../../../lib", __FILE__))

require 'bunny'

HIGH_PRIORITY_Q = "bunny.examples.priority.hilo.high"
LOW_PRIORITY_Q  = "bunny.examples.priority.hilo.low"

conn = Bunny.new(:heartbeat_interval => 8)
conn.start

ch1  = conn.create_channel
ch2  = conn.create_channel
hi_q = ch1.queue(HIGH_PRIORITY_Q, :durable => false)
lo_q = ch2.queue(LOW_PRIORITY_Q,  :durable => false)

ch3  = conn.create_channel
x    = ch3.default_exchange

# create a backlog of low priority messages
30.times do
  x.publish(rand.to_s, :routing_key => LOW_PRIORITY_Q)
end

# and a much smaller one of high priority messages
3.times do
  x.publish(rand.to_s, :routing_key => HIGH_PRIORITY_Q)
end

hi_q.subscribe do |delivery_info, metadata, payload|
  puts "[high] Consumed #{payload}"
end

lo_q.subscribe do |delivery_info, metadata, payload|
  puts "[low] Consumed #{payload}"
end

loop do
  sleep 0.5
  data = rand.to_s
  rk   = [HIGH_PRIORITY_Q, LOW_PRIORITY_Q].sample

  x.publish(data, :routing_key => rk)
  puts "Published #{data}, routing key: #{rk}"
end

Version data entries

57 entries across 57 versions & 1 rubygems

Version	Path
bunny-2.11.0.pre1	examples/consumers/high_and_low_priority.rb
bunny-2.10.0	examples/consumers/high_and_low_priority.rb
bunny-2.9.2	examples/consumers/high_and_low_priority.rb
bunny-2.9.1	examples/consumers/high_and_low_priority.rb
bunny-2.6.7	examples/consumers/high_and_low_priority.rb
bunny-2.7.4	examples/consumers/high_and_low_priority.rb
bunny-2.8.1	examples/consumers/high_and_low_priority.rb
bunny-2.9.0	examples/consumers/high_and_low_priority.rb
bunny-2.7.3	examples/consumers/high_and_low_priority.rb
bunny-2.8.0	examples/consumers/high_and_low_priority.rb
bunny-2.7.2	examples/consumers/high_and_low_priority.rb
bunny-2.7.1	examples/consumers/high_and_low_priority.rb
bunny-2.7.0	examples/consumers/high_and_low_priority.rb
bunny-2.6.6	examples/consumers/high_and_low_priority.rb
bunny-2.6.5	examples/consumers/high_and_low_priority.rb
bunny-2.6.4	examples/consumers/high_and_low_priority.rb
bunny-2.6.3	examples/consumers/high_and_low_priority.rb
bunny-2.6.2	examples/consumers/high_and_low_priority.rb
bunny-2.6.1	examples/consumers/high_and_low_priority.rb
bunny-2.6.0	examples/consumers/high_and_low_priority.rb