17 lines
448 B
Ruby
17 lines
448 B
Ruby
class ResumeMailingsJob < ApplicationJob
|
|
queue_as :mailers
|
|
|
|
def perform
|
|
Mailing.sending.due_to_send.find_each do |mailing|
|
|
next unless Mailings::SendClock.new(mailing).open?
|
|
|
|
recipient = mailing.mailing_recipients.pending.order(:id).first
|
|
next unless recipient
|
|
|
|
SendMailingRecipientJob.perform_later(recipient.id)
|
|
end
|
|
|
|
DrainOutboundJob.perform_later if Mailings::OutboundQueue.queued_scope.exists?
|
|
end
|
|
end
|