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() name = queue_name() 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() if [:env].to_s.empty? raise ArgumentError, ":env option in required for QueueLocator.queue_name" end if [:queue].to_s.empty? raise ArgumentError, ":queue option in required for QueueLocator.queue_name" end "#{[:env]}-#{[:queue]}#{uniqifier([: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 |