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