Sha256: 59135c7aecdc069c031455f303286c9a2228a1a671e1e3f6507efb6888ba1d45
Contents?: true
Size: 533 Bytes
Versions: 34
Compression:
Stored size: 533 Bytes
Contents
class CommunicationJob < ActiveJob::Base
queue_as :default
self.queue_adapter = :delayed_job
##we currently log all exceptions to redis.
rescue_from(StandardError) do |exception|
puts exception.message
puts exception.backtrace.join("\n")
end
def perform(arguments)
if communication = Auth.configuration.communication_class.constantize.find_communication(arguments)
if time = communication.deliver_all
CommunicationJob.set(wait_until: time).perform_later(arguments)
end
end
end
end
Version data entries
34 entries across 34 versions & 1 rubygems