# Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
# SPDX-License-Identifier: Apache-2.0

# Purpose
# This code example demonstrates how to:
# 1. Get a list of your queues.
# 2. Create a queue.
# 3. Get the queue's URL.
# 4. Delete the queue.

# snippet-start:[ruby.example_code.sqs.ScenarioGettingStarted]

require 'aws-sdk-sqs' # v2: require 'aws-sdk'
# Replace us-west-2 with the AWS Region you're using for Amazon SQS.
sqs = Aws::SQS::Client.new(region: 'us-west-2')

# Get a list of your queues.
sqs.list_queues.queue_urls.each do |queue_url|
  puts queue_url
end

# Create a queue.
queue_name = 'my-queue'

begin
  sqs.create_queue({
                     queue_name: queue_name,
                     attributes: {
                       'DelaySeconds' => '60', # Delay message delivery for 1 minute (60 seconds).
                       'MessageRetentionPeriod' => '86400' # Delete message after 1 day (24 hours * 60 minutes * 60 seconds).
                     }
                   })
rescue Aws::SQS::Errors::QueueDeletedRecently
  puts "A queue with the name '#{queue_name}' was recently deleted. Wait at least 60 seconds and try again."
  exit(false)
end

# Get the queue's URL.
queue_url = sqs.get_queue_url(queue_name: queue_name).queue_url
puts queue_url

begin
  # Create a message with three custom attributes: Title, Author, and WeeksOn.
  send_message_result = sqs.send_message({
                                           queue_url: queue_url,
                                           message_body: 'Information about current NY Times fiction bestseller for week of 2016-12-11.',

                                           message_attributes: {
                                             'Title' => {
                                               string_value: 'The Whistler',
                                               data_type: 'String'
                                             },
                                             'Author' => {
                                               string_value: 'John Grisham',
                                               data_type: 'String'
                                             },
                                             'WeeksOn' => {
                                               string_value: '6',
                                               data_type: 'Number'
                                             }
                                           }
                                         })
  puts send_message_result.message_id
rescue Aws::SQS::Errors::NonExistentQueue
  puts "A queue named '#{queue_name}' does not exist."
  exit(false)
end

# Receive the message in the queue.
receive_message_result = sqs.receive_message({
                                               queue_url: queue_url,
                                               message_attribute_names: ['All'], # Receive all custom attributes.
                                               max_number_of_messages: 1, # Receive at most one message.
                                               wait_time_seconds: 0 # Do not wait to check for the message.
                                             })

# Display information about the message.
# Display the message's body and each custom attribute value.
receive_message_result.messages.each do |message|
  puts message.body
  puts "Title: #{message.message_attributes['Title']['string_value']}"
  puts "Author: #{message.message_attributes['Author']['string_value']}"
  puts "WeeksOn: #{message.message_attributes['WeeksOn']['string_value']}"

  # Delete the message from the queue.
  sqs.delete_message({
                       queue_url: queue_url,
                       receipt_handle: message.receipt_handle
                     })
end

# Delete the queue.
sqs.delete_queue(queue_url: queue_url)
# snippet-end:[ruby.example_code.sqs.ScenarioGettingStarted]