Module: Asynchronic
- Extended by:
- ClassConfig
- Defined in:
- lib/asynchronic.rb,
lib/asynchronic/job.rb,
lib/asynchronic/error.rb,
lib/asynchronic/process.rb,
lib/asynchronic/version.rb,
lib/asynchronic/environment.rb,
lib/asynchronic/data_store/key.rb,
lib/asynchronic/data_store/redis.rb,
lib/asynchronic/queue_engine/ost.rb,
lib/asynchronic/data_store/helper.rb,
lib/asynchronic/data_store/in_memory.rb,
lib/asynchronic/data_store/lazy_store.rb,
lib/asynchronic/data_store/lazy_value.rb,
lib/asynchronic/queue_engine/in_memory.rb,
lib/asynchronic/data_store/scoped_store.rb,
lib/asynchronic/queue_engine/synchronic.rb,
lib/asynchronic/data_store/no_lazy_store.rb,
lib/asynchronic/data_store/readonly_store.rb
Defined Under Namespace
Modules: DataStore, QueueEngine
Classes: Environment, Error, Job, Process, Worker
Constant Summary
collapse
- RETRY_TIMEOUT =
30
- VERSION =
'1.2.2'
Class Method Summary
collapse
Class Method Details
.[](pid) ⇒ Object
26
27
28
|
# File 'lib/asynchronic.rb', line 26
def self.[](pid)
environment.load_process pid
end
|
.environment ⇒ Object
22
23
24
|
# File 'lib/asynchronic.rb', line 22
def self.environment
Environment.new queue_engine, data_store
end
|
.processes ⇒ Object
30
31
32
|
# File 'lib/asynchronic.rb', line 30
def self.processes
environment.processes
end
|
.retry_execution(a_class, message) ⇒ Object
34
35
36
37
38
39
40
41
42
43
|
# File 'lib/asynchronic.rb', line 34
def self.retry_execution(a_class, message)
begin
result = yield
rescue Exception => ex
logger.error(a_class) { "Retrying #{message}. ERROR: #{ex.message}" }
sleep RETRY_TIMEOUT
retry
end
result
end
|