Module: SolidQueue

Defined in:
lib/solid_queue_mongoid.rb,
lib/solid_queue_mongoid/models/job.rb,
lib/solid_queue_mongoid/models/pause.rb,
lib/solid_queue_mongoid/models/queue.rb,
lib/solid_queue_mongoid/models/record.rb,
lib/solid_queue_mongoid/models/classes.rb,
lib/solid_queue_mongoid/models/process.rb,
lib/solid_queue_mongoid/models/execution.rb,
lib/solid_queue_mongoid/models/semaphore.rb,
lib/solid_queue_mongoid/models/job/clearable.rb,
lib/solid_queue_mongoid/models/job/retryable.rb,
lib/solid_queue_mongoid/models/job/executable.rb,
lib/solid_queue_mongoid/models/job/recurrable.rb,
lib/solid_queue_mongoid/models/queue_selector.rb,
lib/solid_queue_mongoid/models/recurring_task.rb,
lib/solid_queue_mongoid/models/job/schedulable.rb,
lib/solid_queue_mongoid/models/ready_execution.rb,
lib/solid_queue_mongoid/models/failed_execution.rb,
lib/solid_queue_mongoid/models/process/executor.rb,
lib/solid_queue_mongoid/models/process/prunable.rb,
lib/solid_queue_mongoid/models/blocked_execution.rb,
lib/solid_queue_mongoid/models/claimed_execution.rb,
lib/solid_queue_mongoid/models/recurring_execution.rb,
lib/solid_queue_mongoid/models/scheduled_execution.rb,
lib/solid_queue_mongoid/models/execution/dispatching.rb,
lib/solid_queue_mongoid/models/execution/job_attributes.rb,
lib/solid_queue_mongoid/models/job/concurrency_controls.rb,
lib/solid_queue_mongoid/models/recurring_task/arguments.rb

Overview

This file pre-declares all the main model classes without their concerns. Must be loaded BEFORE concern files to avoid superclass mismatch errors.

Defined Under Namespace

Classes: BlockedExecution, ClaimedExecution, Execution, FailedExecution, Job, Pause, Process, Queue, QueueSelector, ReadyExecution, Record, RecurringExecution, RecurringTask, ScheduledExecution, Semaphore

Class Method Summary collapse

Class Method Details

.clear_finished_jobs_after ⇒ Object



64
65
66
# File 'lib/solid_queue_mongoid.rb', line 64

def self.clear_finished_jobs_after
  1.day
end

.client ⇒ Object



53
54
55
# File 'lib/solid_queue_mongoid.rb', line 53

def self.client
  SolidQueueMongoid.client
end

.collection_prefix ⇒ Object



57
58
59
# File 'lib/solid_queue_mongoid.rb', line 57

def self.collection_prefix
  SolidQueueMongoid.collection_prefix
end

.instrument(_event, payload = {}) {|payload| ... } ⇒ Object

Yields:

  • (payload)


85
86
87
# File 'lib/solid_queue_mongoid.rb', line 85

def self.instrument(_event, payload = {}, &block)
  yield(payload) if block_given?
end

.preserve_finished_jobs? ⇒ Boolean

Returns:

  • (Boolean)


76
77
78
# File 'lib/solid_queue_mongoid.rb', line 76

def self.preserve_finished_jobs?
  true
end

.process_alive_threshold ⇒ Object



70
71
72
# File 'lib/solid_queue_mongoid.rb', line 70

def self.process_alive_threshold
  5.minutes
end