require 'forwardable' require 'securerandom' require 'redis' require 'ost' require 'class_config' require 'transparent_proxy' require 'logger' Dir.glob(File.expand_path('asynchronic/**/*.rb', File.dirname(__FILE__))).sort.each { |f| require f } module Asynchronic extend ClassConfig attr_config :default_queue, :asynchronic attr_config :queue_engine, QueueEngine::InMemory.new attr_config :data_store, DataStore::InMemory.new attr_config :logger, Logger.new($stdout) RETRY_TIMEOUT = 30 def self.environment Environment.new queue_engine, data_store end def self.[](pid) environment.load_process pid end def self.processes environment.processes end def self.retry_execution(a_class, message) begin result = yield rescue Exception => ex logger.info(a_class) { "Retrying #{message}. ERROR: #{ex.message}" } sleep RETRY_TIMEOUT retry end result end end