Contents

require 'yaml'
require 'shoryuken'

# load SQS credentials
config = YAML.load File.read(File.join(File.expand_path('..', __FILE__), 'shoryuken.yml'))

Aws.config = config['aws']

sqs = Aws::SQS::Client.new

default_queue_url = sqs.create_queue(queue_name: 'default').queue_url

if sqs.config['endpoint'] =~ /amazonaws.com/
  # create a dead letter queue
  # after 7 attempts SQS will move the message to the dead letter queue

  dead_letter_queue_url = sqs.create_queue(queue_name: 'default_failures').queue_url

  dead_letter_queue_arn = sqs.get_queue_attributes(
    queue_url: dead_letter_queue_url,
    attribute_names: %w(QueueArn)
  ).attributes['QueueArn']

  attributes = {}
  attributes['RedrivePolicy'] = %Q({"maxReceiveCount":"7", "deadLetterTargetArn":"#{dead_letter_queue_arn}"})

  sqs.set_queue_attributes queue_url: default_queue_url, attributes: attributes
end

Version data entries

42 entries across 42 versions & 1 rubygems

Version	Path
shoryuken-3.2.3	examples/bootstrap_queues.rb
shoryuken-3.2.2	examples/bootstrap_queues.rb
shoryuken-3.2.1	examples/bootstrap_queues.rb
shoryuken-3.2.0	examples/bootstrap_queues.rb
shoryuken-3.1.12	examples/bootstrap_queues.rb
shoryuken-3.1.11	examples/bootstrap_queues.rb
shoryuken-3.1.10	examples/bootstrap_queues.rb
shoryuken-3.1.9	examples/bootstrap_queues.rb
shoryuken-3.1.8	examples/bootstrap_queues.rb
shoryuken-3.1.7	examples/bootstrap_queues.rb
shoryuken-3.1.6	examples/bootstrap_queues.rb
shoryuken-3.1.5	examples/bootstrap_queues.rb
shoryuken-3.1.4	examples/bootstrap_queues.rb
shoryuken-3.1.3	examples/bootstrap_queues.rb
shoryuken-3.1.2	examples/bootstrap_queues.rb
shoryuken-3.1.1	examples/bootstrap_queues.rb
shoryuken-3.1.0	examples/bootstrap_queues.rb
shoryuken-3.0.11	examples/bootstrap_queues.rb
shoryuken-3.0.10	examples/bootstrap_queues.rb
shoryuken-3.0.9	examples/bootstrap_queues.rb