Sha256: 2f1814630e4ccaf81aded18263a9cf69949886ecda144cd3ac65a653dc48757f

Contents?: true

Size: 507 Bytes

Versions: 2

Compression:

Stored size: 507 Bytes

Contents

module RosettaQueue
  module Gateway

    describe "a fanout exchange adapter", :shared => true do

#       it "should discover fanout name for destation" do
#         when_receiving_exchange {
#           @channel.should_receive(:fanout).with(@exchange).and_return(@bound_queue)
#         }
#       end
    
      it "should bind to fanout exchange" do
        when_receiving_exchange {
          @queue.should_receive(:bind).with(@exchange).and_return(@bound_queue)
        }
      end

    end
  end
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version Path
bmabey-rosetta_queue-0.2.0 spec/rosetta_queue/adapters/shared_fanout_behavior.rb
cwyckoff-rosetta_queue-0.3.3 spec/rosetta_queue/adapters/shared_fanout_behavior.rb