Added multi consumer queues
Added unit tests and fixed code