Added support for blocking queues.