class CassandraEventDeadLettersGroupDAO {

    Flux<Group> retrieveAllGroups() {
        return executor.executeRows(selectAllStatement.bind())
            .map(Throwing.function(row -> Group.deserialize(row.getString(GROUP))));
    }

    @Inject  CassandraEventDeadLettersGroupDAO(Session session);

}