Module: SQSQueueLocator

Defined in:
lib/sqs-queue-locator.rb

Class Method Summary collapse

Class Method Details

.locate(options) ⇒ Object 



4
5
6
7
8
 
# File 'lib/sqs-queue-locator.rb', line 4

def self.locate(options)
  name = queue_name(options)
  sqs = AWS::SQS.new
  sqs.queues.create name
end

.queue_name(options) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
 
# File 'lib/sqs-queue-locator.rb', line 10

def self.queue_name(options)
  if options[:env].to_s.empty?
    raise ArgumentError, ":env option in required for QueueLocator.queue_name"
  end

  if options[:queue].to_s.empty?
    raise ArgumentError, ":queue option in required for QueueLocator.queue_name"
  end

  "#{options[:env]}-#{options[:queue]}#{uniqifier(options[:env])}"
end

.uniqifier(env) ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/sqs-queue-locator.rb', line 22

def self.uniqifier(env)
  if env == "development"
    "-#{Digest::MD5.hexdigest Socket.gethostname}"
  else
    ""
  end
end