Contents

module Eventboss
  module ErrorHandlers
    class NonExistentQueueHandler
      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
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
eventboss-1.9.1	lib/eventboss/error_handlers/non_existent_queue_handler.rb
eventboss-1.9.0	lib/eventboss/error_handlers/non_existent_queue_handler.rb
eventboss-1.8.1	lib/eventboss/error_handlers/non_existent_queue_handler.rb
eventboss-1.8.0	lib/eventboss/error_handlers/non_existent_queue_handler.rb
eventboss-1.7.0	lib/eventboss/error_handlers/non_existent_queue_handler.rb