Module: CycloneLariat::Generators::Queue
- Included in:
- CycloneLariat, Clients::Sqs
- Defined in:
- lib/cyclone_lariat/generators/queue.rb
Instance Method Summary collapse
- #custom_queue(name) ⇒ Object
- #queue(type = :all, fifo:, dest: nil, content_based_deduplication: nil, kind: :event, **options) ⇒ Object
Instance Method Details
#custom_queue(name) ⇒ Object
25 26 27 |
# File 'lib/cyclone_lariat/generators/queue.rb', line 25 def custom_queue(name) Resources::Queue.from_name(name, account_id: config.aws_account_id, region: config.aws_region) end |
#queue(type = :all, fifo:, dest: nil, content_based_deduplication: nil, kind: :event, **options) ⇒ Object
8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
# File 'lib/cyclone_lariat/generators/queue.rb', line 8 def queue(type = :all, fifo:, dest: nil, content_based_deduplication: nil, kind: :event, **) = CycloneLariat::Options.wrap() .merge!(config) Resources::Queue.new( instance: .instance, publisher: .publisher, region: .aws_region, account_id: .aws_account_id, kind: kind, type: type, fifo: fifo, dest: dest, content_based_deduplication: content_based_deduplication ) end |