Sha256: 7887e2ff1664f09ffe8c6c4a9669e556b3fbe6296f86f9bb5523086faaa47c29
Contents?: true
Size: 1.8 KB
Versions: 60
Compression:
Stored size: 1.8 KB
Contents
require "spec_helper"
unless ENV["CI"]
describe Bunny::Queue, "#subscribe" do
let(:connection1) do
c = Bunny.new(:user => "bunny_gem", :password => "bunny_password", :vhost => "bunny_testbed")
c.start
c
end
let(:connection2) do
c = Bunny.new(:user => "bunny_gem", :password => "bunny_password", :vhost => "bunny_testbed")
c.start
c
end
after :all do
connection1.close if connection1.open?
connection2.close if connection2.open?
end
context "with an empty queue" do
it "consumes messages" do
delivered_data = []
ch1 = connection1.create_channel
ch2 = connection1.create_channel
q = ch1.queue("", :exclusive => true)
q.subscribe(:ack => false, :block => false) do |delivery_info, properties, payload|
delivered_data << payload
end
sleep 0.5
x = ch2.default_exchange
x.publish("abc", :routing_key => q.name)
sleep 0.7
delivered_data.should == ["abc"]
ch1.close
ch2.close
end
end
context "with a non-empty queue" do
let(:queue_name) { "queue#{rand}" }
it "consumes messages" do
delivered_data = []
ch1 = connection1.create_channel
ch2 = connection1.create_channel
q = ch1.queue(queue_name, :exclusive => true)
x = ch2.default_exchange
3.times do |i|
x.publish("data#{i}", :routing_key => queue_name)
end
sleep 0.7
q.message_count.should == 3
q.subscribe(:ack => false, :block => false) do |delivery_info, properties, payload|
delivered_data << payload
end
sleep 0.7
delivered_data.should == ["data0", "data1", "data2"]
ch1.close
ch2.close
end
end
end
end
Version data entries
60 entries across 60 versions & 1 rubygems