Combining Queue Pooling and Dedicated Queues
If needed, a combination of queue pooling and dedicated queues can be used. The following example illustrates this.
1. Increase the maximum number of queues in wt.properties:
wt.queue.max.processQueues=100
2. Set the wt.properties required to enable queue pooling:
wt.workflow.engine.userWorkPoolSize=10
wt.workflow.engine.propagationPoolSize=10
wt.workflow.engine.propagationPoolSize=10
After this change, workflow process will pub jobs unto WfUserWorkQueue or WfPropagationQueue in a circular manner, starting with the first and continuing through the queue and then starting over with the first again. Since each queue has a thread pool for processing its jobs, this change creates parallel processing of workflow tasks in the same queue.
3. Set the wt.properties value required to enable dedicated queues for both WfUserWorkQueue and WfPropagationQueue queues:
wt.workflow.engine.dedicatedQueueMode=both
 |
The value all can also be used instead of the value both, with the same result.
|