Contents

require 'spec_helper'
require 'shoryuken/manager'
require 'shoryuken/fetcher'

RSpec.describe Shoryuken::Fetcher do
  let(:queue)        { instance_double('Shoryuken::Queue') }
  let(:queue_name)   { 'default' }
  let(:queue_config) { Shoryuken::Polling::QueueConfiguration.new(queue_name, {}) }
  let(:group)        { 'default' }

  let(:sqs_msg) do
    double(
      Shoryuken::Message,
      queue_url: queue_name,
      body: 'test',
      message_id: 'fc754df79cc24c4196ca5996a44b771e',
    )
  end

  subject { described_class.new(group) }

  describe '#fetch' do
    let(:limit) { 1 }

    specify do
      expect(Shoryuken::Client).to receive(:queues).with(queue_name).and_return(queue)

      Shoryuken.sqs_client_receive_message_opts[group] = { wait_time_seconds: 10 }

      expect(queue).to receive(:receive_messages).
        with(wait_time_seconds: 10, max_number_of_messages: limit, message_attribute_names: ['All'], attribute_names: ['All']).
        and_return([])

      subject.fetch(queue_config, limit)
    end

    context 'when limit is greater than FETCH_LIMIT' do
      let(:limit) { 20 }

      specify do
        Shoryuken.sqs_client_receive_message_opts[group] = {}

        allow(Shoryuken::Client).to receive(:queues).with(queue_name).and_return(queue)
        expect(queue).to receive(:receive_messages).
          with(max_number_of_messages: described_class::FETCH_LIMIT, attribute_names: ['All'], message_attribute_names: ['All']).
          and_return([])

        subject.fetch(queue_config, limit)
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
shoryuken-3.1.6	spec/shoryuken/fetcher_spec.rb
shoryuken-3.1.5	spec/shoryuken/fetcher_spec.rb
shoryuken-3.1.4	spec/shoryuken/fetcher_spec.rb
shoryuken-3.1.3	spec/shoryuken/fetcher_spec.rb
shoryuken-3.1.2	spec/shoryuken/fetcher_spec.rb
shoryuken-3.1.1	spec/shoryuken/fetcher_spec.rb
shoryuken-3.1.0	spec/shoryuken/fetcher_spec.rb