Added support for partial processing of queue