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