module Asynchronic
Constants
- VERSION
Public Class Methods
[](pid)
click to toggle source
# File lib/asynchronic.rb, line 36 def self.[](pid) environment.load_process pid end
environment()
click to toggle source
# File lib/asynchronic.rb, line 32 def self.environment Environment.new queue_engine, data_store, notifier end
establish_redis_connection(options={})
click to toggle source
# File lib/asynchronic.rb, line 48 def self.establish_redis_connection(options={}) redis_client = options.fetch(:redis_client, Asynchronic.redis_client) redis_settings = options.fetch(:redis_settings, Asynchronic.redis_settings) redis_client.new redis_settings end
garbage_collector()
click to toggle source
# File lib/asynchronic.rb, line 44 def self.garbage_collector @garbage_collector ||= GarbageCollector.new environment, garbage_collector_timeout end
processes()
click to toggle source
# File lib/asynchronic.rb, line 40 def self.processes environment.processes end
retry_execution(klass, message) { || ... }
click to toggle source
# File lib/asynchronic.rb, line 54 def self.retry_execution(klass, message) begin result = yield rescue Exception => ex logger.error(klass) { "Retrying #{message}. ERROR: #{ex.message}" } sleep retry_timeout retry end result end