consume(queueName:string, callback:(job:IJob)=>void) {
        var self = this;

        if(self.consumedQueues[queueName]) {
            throw OnlyOneConsumerPerQueueError();