Contents

# frozen_string_literal: true

require 'delayed_job_recurring'

module Totoro
  class MessageResender
    include Delayed::RecurringJob
    run_every 10.second
    queue 'totoro'
    def perform
      Totoro::Queue.connection
      Totoro::TotoroFailedMessage.find_in_batches(batch_size: 100) do |message_group|
        message_group.each do |m|
          m.class_name.constantize.enqueue(m.queue_id, m.payload)
          m.destroy
        end
      end
    rescue Bunny::TCPConnectionFailedForAllHosts => error
      Rails.logger.error error.message
      STDOUT.flush
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
totoro-0.5.2	lib/totoro/message_resender.rb
totoro-0.5.1	lib/totoro/message_resender.rb