spec/process/life_cycle_examples.rb in asynchronic-1.0.0 vs spec/process/life_cycle_examples.rb in asynchronic-1.1.0

- old
+ new

@@ -399,6 +399,51 @@ process.must_be_completed process.result.must_equal 3 queue.must_be_empty end + it 'Inheritance of queues in processes. Use default queue' do + process = create NestedJob, input: 100 + + process.queue.must_be_nil + + process.enqueue + execute queue + + process.processes.first.queue.must_be_nil + execute queue + + process.processes.first.processes.first.queue.must_be_nil + execute queue + end + + it 'Inheritance of queues in processes. Specify queue in params' do + process = create NestedJob, {input: 100, queue: :test_queue} + + process.queue.must_equal :test_queue + + process.enqueue + execute queue_engine[:test_queue] + + process.processes.first.queue.must_equal :test_queue + execute queue_engine[:test_queue] + + process.processes.first.processes.first.queue.must_equal :test_queue + execute queue_engine[:test_queue] + end + + it 'Inheritance of queues in processes. Redefine queue in job class' do + process = create NestedJobWithDifferentsQueues, {input: 100, queue: :test_queue} + + process.queue.must_equal :test_queue + + process.enqueue + execute queue_engine[:test_queue] + + process.processes.first.queue.must_equal :other_queue + execute queue_engine[:other_queue] + + process.processes.first.processes.first.queue.must_equal :other_queue + execute queue_engine[:other_queue] + end + end \ No newline at end of file