Sha256: 51fb86330aee2b3fba1887f8394907522ff7461cca0a99c628b040c693cd20b2
Contents?: true
Size: 861 Bytes
Versions: 30
Compression:
Stored size: 861 Bytes
Contents
require "spec_helper" describe Bunny::Exchange do let(:connection) do c = Bunny.new(username: "bunny_gem", password: "bunny_password", vhost: "bunny_testbed") c.start c end after :each do connection.close if connection.open? end it "unbinds two existing exchanges" do ch = connection.create_channel source = ch.fanout("bunny.exchanges.source#{rand}") destination = ch.fanout("bunny.exchanges.destination#{rand}") queue = ch.queue("", exclusive: true) queue.bind(destination) destination.bind(source) source.publish("") sleep 0.5 expect(queue.message_count).to eq 1 queue.pop(manual_ack: true) destination.unbind(source) source.publish("") sleep 0.5 expect(queue.message_count).to eq 0 source.delete destination.delete ch.close end end
Version data entries
30 entries across 30 versions & 1 rubygems