Use fixed-size thread pool with 8 threads and pass it from the Broker to each queue