class Eventboss::ErrorHandlers::NonExistentQueueHandler
Public Instance Methods
call(exception, context = {})
click to toggle source
# File lib/eventboss/error_handlers/non_existent_queue_handler.rb, line 4 def call(exception, context = {}) if exception.class == ::Aws::SQS::Errors::NonExistentQueue queue = context.fetch(:poller_id, "").sub('poller-', '') Eventboss.logger.error("Queue doesn't exist: " + queue) end end