Cassandra-based queue with parallel producers and shared consumers