Module: Delayed

Defined in:

lib/delayed.rb,
lib/delayed/engine.rb,
lib/delayed/plugin.rb,
lib/delayed/worker.rb,
lib/delayed/monitor.rb,
lib/delayed/version.rb,
lib/delayed/priority.rb,
lib/delayed/runnable.rb,
lib/delayed/lifecycle.rb,
lib/delayed/psych_ext.rb,
lib/delayed/psych_ext.rb,
app/models/delayed/job.rb,
lib/delayed/exceptions.rb,
lib/delayed/job_wrapper.rb,
lib/delayed/backend/base.rb,
lib/delayed/message_sending.rb,
lib/delayed/helpers/migration.rb,
lib/delayed/active_job_adapter.rb,
lib/delayed/performable_mailer.rb,
lib/delayed/performable_method.rb,
lib/delayed/plugins/connection.rb,
lib/delayed/backend/job_preparer.rb,
lib/delayed/plugins/instrumentation.rb

Defined Under Namespace

Modules: Backend, DelayMail, Helpers, MessageSending, MessageSendingClassMethods, Plugins, PsychExt, Runnable Classes: ActiveJobAdapter, Callback, DelayProxy, DeserializationError, Engine, FatalBackendError, InvalidCallback, Job, JobWrapper, Lifecycle, Monitor, PerformableMailer, PerformableMethod, Plugin, Priority, Worker, WorkerTimeout

Constant Summary

VERSION =

'2.0.0'

Class Method Summary

• .lifecycle ⇒ Object
• .logger ⇒ Object
• .logger=(value) ⇒ Object
• .say(message, level = default_log_level) ⇒ Object
• .setup_lifecycle ⇒ Object

Class Method Details

.lifecycle ⇒ Object

# File 'lib/delayed.rb', line 51

def self.lifecycle
  setup_lifecycle unless @lifecycle
  @lifecycle
end

.logger ⇒ Object

# File 'lib/delayed.rb', line 61

def self.logger
  @logger ||= Rails.logger
end

.logger=(value) ⇒ Object

# File 'lib/delayed.rb', line 65

def self.logger=(value)
  @logger = value
end

.say(message, level = default_log_level) ⇒ Object

# File 'lib/delayed.rb', line 69

def self.say(message, level = default_log_level)
  logger&.send(level, message)
end

.setup_lifecycle ⇒ Object

# File 'lib/delayed.rb', line 56

def self.setup_lifecycle
  @lifecycle = Delayed::Lifecycle.new
  plugins.each { |klass| klass.new }
end