Sha256: c0b2dcb13562843c53fcffaa2c8cb0bcfc8efe91be06a71cf4b1d51d8315a135
Contents?: true
Size: 583 Bytes
Versions: 10
Compression:
Stored size: 583 Bytes
Contents
module Taskinator
module Queues
def self.create_test_queue_adapter(config={})
TestQueueAdapter::new()
end
class TestQueueAdapter
attr_reader :processes
attr_reader :tasks
attr_reader :jobs
def initialize
clear
end
def clear
@processes = []
@tasks = []
@jobs = []
end
def enqueue_process(process)
@processes << process
end
def enqueue_task(task)
@tasks << task
end
def enqueue_job(job)
@jobs << job
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems