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