Sha256: 232dba0195c256e01e3e1ed3a3990faee4dfec262652629da9faf725f69a0a05
Contents?: true
Size: 699 Bytes
Versions: 17
Compression:
Stored size: 699 Bytes
Contents
require "spec_helper"
describe "Any queue" do
#
# Environment
#
let(:connection) { HotBunnies.connect }
let(:channel) { connection.create_channel }
after :each do
channel.close
connection.close
end
#
# Examples
#
it "can be purged" do
exchange = channel.exchange("amq.fanout", :type => :fanout, :durable => true, :auto_delete => false)
queue = channel.queue("", :auto_delete => true)
exchange.publish("")
queue.get.should be_nil
queue.purge
queue.get.should be_nil
queue.bind(exchange)
exchange.publish("", :routing_key => queue.name)
queue.get.should_not be_nil
queue.purge
queue.get.should be_nil
end
end
Version data entries
17 entries across 17 versions & 1 rubygems