Module: Soter
- Defined in:
- lib/soter.rb,
lib/soter/config.rb,
lib/soter/job_worker.rb
Defined Under Namespace
Classes: Config, JobWorker
Class Method Summary
collapse
Class Method Details
.config ⇒ Object
11
12
13
|
# File 'lib/soter.rb', line 11
def self.config
@config ||= Soter::Config.new
end
|
.dequeue(job_params) ⇒ Object
29
30
31
|
# File 'lib/soter.rb', line 29
def self.dequeue(job_params)
queue.remove('job_params' => job_params)
end
|
.enqueue(handler, job_params = {}, queue_options = {}) ⇒ Object
15
16
17
18
19
20
21
22
23
24
25
26
27
|
# File 'lib/soter.rb', line 15
def self.enqueue(handler, job_params={}, queue_options={})
job = {
'job' => {
'params' => job_params,
'class' => handler.to_s
},
'queue_options' => queue_options,
'active_at' => queue_options.delete(:active_at)
}
queue.insert(job)
dispatch_worker
end
|