diff --git a/Thread-pool wait 10 seconds.png b/Thread-pool wait 10 seconds.png new file mode 100644 index 00000000..0407ad59 Binary files /dev/null and b/Thread-pool wait 10 seconds.png differ diff --git a/lib/shoryuken/fetcher.rb b/lib/shoryuken/fetcher.rb index 7297082d..2697c8f4 100644 --- a/lib/shoryuken/fetcher.rb +++ b/lib/shoryuken/fetcher.rb @@ -33,6 +33,8 @@ def receive_messages(queue, limit) options[:max_number_of_messages] = limit options[:message_attribute_names] = %w(All) options[:attribute_names] = %w(All) + options[:wait_time_seconds] = 10 + options.merge!(queue.options)