Module: Delayed

Defined in:

lib/generators/delayed/migration_generator.rb,
lib/delayed.rb,
lib/delayed/engine.rb,
lib/delayed/plugin.rb,
lib/delayed/worker.rb,
lib/delayed/monitor.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/backend/base.rb,
lib/delayed/message_sending.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/generators/delayed/generator.rb,
lib/delayed/plugins/instrumentation.rb,
lib/generators/delayed/next_migration_version.rb

Overview

Extend the DelayedJobGenerator so that it creates an AR migration

Defined Under Namespace

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

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 49

def self.lifecycle
  setup_lifecycle unless @lifecycle
  @lifecycle
end

.logger ⇒ Object

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

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

.logger=(value) ⇒ Object

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

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

.say(message, level = default_log_level) ⇒ Object

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

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

.setup_lifecycle ⇒ Object

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

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