Contents

require 'spec_helper'

describe Alephant::Publisher::Queue::SQSHelper::Queue do
  describe "#message" do
    it "returns a message" do
      m = double("message").as_null_object
      q = double("queue").as_null_object

      expect(q).to receive(:receive_message).and_return(m)

      instance = Alephant::Publisher::Queue::SQSHelper::Queue.new(q)

      expect(instance.message).to eq(m)
    end

    it "call see(m) on the handed archiver" do
      a = double("archiver").as_null_object
      m = double("message").as_null_object
      q = double("queue").as_null_object

      expect(q).to receive(:receive_message).and_return(m)
      expect(a).to receive(:see).with(m)

      instance = Alephant::Publisher::Queue::SQSHelper::Queue.new(q, a)

      expect(instance.message).to eq(m)
    end
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

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