updated with CassandraQueue abstraction