Contents

module RosettaQueue
  module Gateway

    describe "an adapter", :shared => true do

      before(:each) do
        ::RosettaQueue::Destinations.stub!(:lookup).and_return("/queue/foo")
      end

      def do_publishing
        @adapter.send_message('queue', 'message', 'options')
      end

      def do_receiving_with_handler
        @adapter.receive_with(@handler)
      end
      
      describe "#receive_once" do

        it "should return the message from the connection" do
          @adapter.receive_once("/queue/foo", {:persistent => false}).should == @msg
        end

      end
          
      describe "#receive_with" do

        it "should look up the destination defined on the class" do
          when_receiving_with_handler {
            Destinations.should_receive(:lookup).with(:foo).and_return("/queue/foo")
          }
        end
      
      end
      
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
bmabey-rosetta_queue-0.1.3	spec/rosetta_queue/adapters/shared_adapter_behavior.rb