Module: CycloneLariat::Generators::Queue

Included in:
CycloneLariat, Clients::Sqs
Defined in:
lib/cyclone_lariat/generators/queue.rb

Instance Method Summary collapse

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., 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, **options)
  options = CycloneLariat::Options.wrap(options)
  options.merge!(config)

  Resources::Queue.new(
    instance: options.instance,
    publisher: options.publisher,
    region: options.aws_region,
    account_id: options.,
    kind: kind,
    type: type,
    fifo: fifo,
    dest: dest,
    content_based_deduplication: content_based_deduplication
  )
end