module Asynchronic

# File lib/asynchronic.rb, line 36
def self.[](pid)
  environment.load_process pid
end

# File lib/asynchronic.rb, line 32
def self.environment
  Environment.new queue_engine, data_store, notifier
end

# 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

# File lib/asynchronic.rb, line 44
def self.garbage_collector
  @garbage_collector ||= GarbageCollector.new environment, garbage_collector_timeout
end

# File lib/asynchronic.rb, line 40
def self.processes
  environment.processes
end

# 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