Replaced the zookeeper distributed queue with a distributed priority queue to solve the problem of consuming re-queued messages out of their initial ordering