CassandraEventDeadLettersDAO { Flux<EventDeadLetters.InsertionId> retrieveInsertionIdsWithGroup(Group group) { return executor.executeRows(selectEventIdsWithGroupStatement.bind() .setString(GROUP, group.asString())) .map(row -> EventDeadLetters.InsertionId.of(row.getUUID(INSERTION_ID))); } @Inject  CassandraEventDeadLettersDAO(Session session, EventSerializer eventSerializer);   }
@Test void retrieveInsertionIdsWithGroupShouldReturnEmptyWhenDefault() { assertThat(cassandraEventDeadLettersDAO .retrieveInsertionIdsWithGroup(GROUP_A) .collectList().block()) .isEmpty(); }