class CassandraDeletedMessageDAO {

    public Flux<MessageUid> retrieveDeletedMessage(CassandraId cassandraId, MessageRange range) {
        return retrieveResultSetOfDeletedMessage(cassandraId, range)
            .flatMapMany(this::resultSetToFlux);
    }

    @Inject public  CassandraDeletedMessageDAO(Session session, CassandraUtils cassandraUtils);
    @VisibleForTesting public  CassandraDeletedMessageDAO(Session session);

}