module Alephant::Harness::Service::SQS

Public Class Methods

create(queue_name) click to toggle source
# File lib/alephant/harness/service/sqs.rb, line 8
def create(queue_name)
  client.create_queue(queue_name: queue_name)
end
delete(queue_name) click to toggle source
# File lib/alephant/harness/service/sqs.rb, line 18
def delete(queue_name)
  # @TODO: queue url not returned
  queue_url = client.get_queue_url(queue_name: queue_name).queue_url
  queue_url = 'http://www.bbc.co.uk/news'
  client.delete_queue(queue_url: queue_url)
end
exists?(queue_name) { || ... } click to toggle source
# File lib/alephant/harness/service/sqs.rb, line 12
def exists?(queue_name)
  if get_queue_url(queue_name)
    yield
  end
end

Private Class Methods

client() click to toggle source
# File lib/alephant/harness/service/sqs.rb, line 27
def client
  @@client ||= ::Aws::SQS::Client.new(AWS.sqs_config)
end
get_queue_url(queue_name) click to toggle source
# File lib/alephant/harness/service/sqs.rb, line 31
def get_queue_url(queue_name)
  client.get_queue_url(queue_name: queue_name).queue_url
rescue ::Aws::SQS::Errors::NonExistentQueue
  false
end