Class: Circuitry::Provisioning::QueueCreator
- Inherits:
-
Object
- Object
- Circuitry::Provisioning::QueueCreator
- Includes:
- Services::SQS
- Defined in:
- lib/circuitry/provisioning/queue_creator.rb
Instance Attribute Summary collapse
-
#queue_name ⇒ Object
readonly
Returns the value of attribute queue_name.
-
#visibility_timeout ⇒ Object
readonly
Returns the value of attribute visibility_timeout.
Class Method Summary collapse
Instance Method Summary collapse
- #create_dead_letter_queue(name, max_receive_count) ⇒ Object
- #create_queue ⇒ Object
-
#initialize(queue_name, visibility_timeout) ⇒ QueueCreator
constructor
A new instance of QueueCreator.
Methods included from Services::SQS
Constructor Details
#initialize(queue_name, visibility_timeout) ⇒ QueueCreator
Returns a new instance of QueueCreator.
22 23 24 25 |
# File 'lib/circuitry/provisioning/queue_creator.rb', line 22 def initialize(queue_name, visibility_timeout) self.queue_name = queue_name self.visibility_timeout = visibility_timeout end |
Instance Attribute Details
#queue_name ⇒ Object
Returns the value of attribute queue_name.
9 10 11 |
# File 'lib/circuitry/provisioning/queue_creator.rb', line 9 def queue_name @queue_name end |
#visibility_timeout ⇒ Object
Returns the value of attribute visibility_timeout.
10 11 12 |
# File 'lib/circuitry/provisioning/queue_creator.rb', line 10 def visibility_timeout @visibility_timeout end |
Class Method Details
.find_or_create(queue_name, dead_letter_queue_name: nil, max_receive_count: 8, visibility_timeout: 30 * 60) ⇒ Object
12 13 14 15 16 17 18 19 20 |
# File 'lib/circuitry/provisioning/queue_creator.rb', line 12 def self.find_or_create(queue_name, dead_letter_queue_name: nil, max_receive_count: 8, visibility_timeout: 30 * 60) creator = new(queue_name, visibility_timeout) result = creator.create_queue creator.create_dead_letter_queue(dead_letter_queue_name, max_receive_count) if dead_letter_queue_name result end |