Sha256: f6c2ef23b8b65b9369b93af337d1ec939d369b47f4c68c401f8e0239c5f8f978
Contents?: true
Size: 1.09 KB
Versions: 17
Compression:
Stored size: 1.09 KB
Contents
require "spec_helper"
describe "Queue" do
context "with a server-generated name" do
let(:connection) { HotBunnies.connect }
let(:channel) { connection.create_channel }
after :each do
channel.close
connection.close
end
it "can be declared as auto-deleted" do
channel.queue("", :auto_delete => true)
end
it "can be declared as auto-deleted and non-durable" do
channel.queue("", :auto_delete => true, :durable => false)
end
it "can be declared as NON-auto-deleted" do
channel.queue("", :auto_delete => false)
end
it "can be declared as NON-durable" do
channel.queue("", :durable => false)
end
it "can be declared with additional attributes like x-message-ttle" do
queue = channel.queue("", :durable => false, :arguments => { 'x-message-ttl' => 2000 })
exchange = channel.exchange("", :type => :direct)
100.times do |i|
exchange.publish("Message #{i}", :routing_key => queue.name)
end
queue.get.should_not be_nil
sleep(2.1)
queue.get.should be_nil
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems