class Totoro::ResendService

Public Instance Methods

resend_all_messages() click to toggle source
# File lib/totoro/services/resend_service.rb, line 5
def resend_all_messages
  Totoro::TotoroFailedMessage.find_in_batches(batch_size: 100) do |message_group|
    message_group.each { |m| resend_message(m) }
  end
end

Private Instance Methods

resend_message(failed_message) click to toggle source
# File lib/totoro/services/resend_service.rb, line 13
def resend_message(failed_message)
  queue_class = failed_message.class_name.constantize
  queue_class.method(failed_message.group).call(failed_message.queue_id, failed_message.payload)
  failed_message.destroy
end