Sha256: 8c014fa2da0521e547de0f9357abc8a11f87137aef5521cd34a3bf3e85671095

Contents?: true

Size: 692 Bytes

Versions: 3

Compression:

Stored size: 692 Bytes

Contents

require 'procrastinator/version'
require 'procrastinator/queue_worker'
require 'procrastinator/task_worker'
require 'procrastinator/environment'
require 'logger'


module Procrastinator
   @@test_mode = false

   def self.setup(persister, &block)
      raise ArgumentError.new('Procrastinator.setup must be given a block') if block.nil?

      env = Environment.new(persister: persister, test_mode: @@test_mode)

      yield(env)

      raise RuntimeError.new('setup block did not define any queues') if env.queue_definitions.empty?

      env.spawn_workers

      env
   end

   def self.test_mode=(value)
      @@test_mode = value
   end

   def self.test_mode
      @@test_mode
   end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
procrastinator-0.5.0 lib/procrastinator.rb
procrastinator-0.4.1 lib/procrastinator.rb
procrastinator-0.4.0 lib/procrastinator.rb