inner queue of PumpingQueue structure changed into BlockingQueue.