Contents

module RosettaQueue

  describe "a consumer manager", :shared => true do

    def do_process
      @manager.start
    end

    describe ".add" do

      def do_process
        @manager.add(@message_handler)
      end

      it "should load message_handler into consumer" do
        during_process { Consumer.should_receive(:new).with(@message_handler) }
      end

      it "should allow user to add new consumers" do
        @manager.consumers.size.should == 1
      end

    end

  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
bmabey-rosetta_queue-0.3.3	spec/rosetta_queue/consumer_managers/shared_manager_behavior.rb
rosetta_queue-0.5.2	spec/rosetta_queue/consumer_managers/shared_manager_behavior.rb
rosetta_queue-0.5.0	spec/rosetta_queue/consumer_managers/shared_manager_behavior.rb
rosetta_queue-0.4.0	spec/rosetta_queue/consumer_managers/shared_manager_behavior.rb