Class: Fare::QueueAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/fare/queue_adapter.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(environment, name) ⇒ QueueAdapter

Returns a new instance of QueueAdapter.



10
11
12
13
 
# File 'lib/fare/queue_adapter.rb', line 10

def initialize(environment, name)
  @environment = environment
  @name = name
end

Instance Attribute Details

#environment ⇒ Object (readonly)

Returns the value of attribute environment.



8
9
10
 
# File 'lib/fare/queue_adapter.rb', line 8

def environment
  @environment
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



8
9
10
 
# File 'lib/fare/queue_adapter.rb', line 8

def name
  @name
end

Class Method Details

.fetch(*args) ⇒ Object 



4
5
6
 
# File 'lib/fare/queue_adapter.rb', line 4

def self.fetch(*args)
  new(*args).queue
end

Instance Method Details

#queue ⇒ Object 



15
16
17
18
19
20
21
 
# File 'lib/fare/queue_adapter.rb', line 15

def queue
  sqs.queues.named(queue_name)
rescue AWS::SQS::Errors::NonExistentQueue
  sqs.queues.create(queue_name).tap { |queue|
    queue.wait_time_seconds = 20
  }
end

#queue_name ⇒ Object 



23
24
25
 
# File 'lib/fare/queue_adapter.rb', line 23

def queue_name
  "#{environment}-#{name}"
end

#sqs ⇒ Object 



27
28
29
 
# File 'lib/fare/queue_adapter.rb', line 27

def sqs
  AWS::SQS.new
end