Generic message producers/consumers pattern using a set of unbounded persisted queues - View it on GitHub