Contents

require 'spec_helper'

describe Alephant::Publisher::Queue::Processor do

  before(:each) do
    allow_any_instance_of(Alephant::Publisher::Queue::Writer).to receive(:initialize)
    allow_any_instance_of(Alephant::Publisher::Queue::Writer).to receive(:run!)
  end

  describe "#consume(msg)" do
    it "Consume the message and deletes it" do

      msg = double('AWS::SQS::ReceivedMessage', :delete => nil)
      expect(msg).to receive(:delete)
      subject.consume(msg)

    end
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
alephant-publisher-queue-2.0.0	spec/processor_spec.rb
alephant-publisher-queue-1.4.1	spec/processor_spec.rb
alephant-publisher-queue-1.4.0	spec/processor_spec.rb
alephant-publisher-queue-1.3.6	spec/processor_spec.rb
alephant-publisher-queue-1.3.5	spec/processor_spec.rb
alephant-publisher-queue-1.3.4	spec/processor_spec.rb
alephant-publisher-queue-1.3.3	spec/processor_spec.rb
alephant-publisher-queue-1.3.2	spec/processor_spec.rb
alephant-publisher-queue-1.2.2	spec/processor_spec.rb
alephant-publisher-queue-1.2.1	spec/processor_spec.rb
alephant-publisher-queue-1.2.0	spec/processor_spec.rb
alephant-publisher-queue-1.1.0	spec/processor_spec.rb
alephant-publisher-queue-1.0.0	spec/processor_spec.rb
alephant-publisher-queue-0.1.0	spec/processor_spec.rb
alephant-publisher-queue-0.0.1	spec/processor_spec.rb