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