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 |