Using dataflow for managing the queueing system.