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

9 entries across 9 versions & 1 rubygems

Version	Path
alephant-publisher-queue-2.2.0	spec/processor_spec.rb
alephant-publisher-queue-2.1.4	spec/processor_spec.rb
alephant-publisher-queue-2.1.3	spec/processor_spec.rb
alephant-publisher-queue-2.1.2	spec/processor_spec.rb
alephant-publisher-queue-2.1.1	spec/processor_spec.rb
alephant-publisher-queue-2.1.0	spec/processor_spec.rb
alephant-publisher-queue-2.0.3	spec/processor_spec.rb
alephant-publisher-queue-2.0.2	spec/processor_spec.rb
alephant-publisher-queue-2.0.1	spec/processor_spec.rb