class Mimi::Messaging::SQS_SNS::TemporaryQueueConsumer

Temporary queue consumer creates a temporary queue and attaches to it. The queue will be deleted on consumer shutdown.

Attributes

queue_url[R]

Public Class Methods

new(adapter, queue_name, &block) click to toggle source
# File lib/mimi/messaging/sqs_sns/temporary_queue_consumer.rb, line 14
def initialize(adapter, queue_name, &block)
  @adapter = adapter
  @queue_url = adapter.find_or_create_queue(queue_name)
  @consumer = Consumer.new(adapter, @queue_url, &block)
end

Public Instance Methods

stop() click to toggle source
# File lib/mimi/messaging/sqs_sns/temporary_queue_consumer.rb, line 20
def stop
  @consumer.stop
  @adapter.delete_queue(queue_url)
rescue StandardError => e
  raise Mimi::Messaging::Error, "Failed to stop temporary queue consumer: #{e}"
end