@Test void retrieveFailedEventShouldReturnEmptyWhenDefault() { assertThat(cassandraEventDeadLettersDAO .retrieveFailedEvent(GROUP_A, INSERTION_ID_1) .blockOptional().isPresent()) .isFalse(); }
Mono<Event> retrieveFailedEvent(Group group, EventDeadLetters.InsertionId insertionId) { return executor.executeSingleRow(selectEventStatement.bind() .setString(GROUP, group.asString()) .setUUID(INSERTION_ID, insertionId.getId())) .map(row -> deserializeEvent(row.getString(EVENT))); }
CassandraEventDeadLettersDAO { Mono<Event> retrieveFailedEvent(Group group, EventDeadLetters.InsertionId insertionId) { return executor.executeSingleRow(selectEventStatement.bind() .setString(GROUP, group.asString()) .setUUID(INSERTION_ID, insertionId.getId())) .map(row -> deserializeEvent(row.getString(EVENT))); } }
CassandraEventDeadLettersDAO { Mono<Event> retrieveFailedEvent(Group group, EventDeadLetters.InsertionId insertionId) { return executor.executeSingleRow(selectEventStatement.bind() .setString(GROUP, group.asString()) .setUUID(INSERTION_ID, insertionId.getId())) .map(row -> deserializeEvent(row.getString(EVENT))); } @Inject  CassandraEventDeadLettersDAO(Session session, EventSerializer eventSerializer); }
CassandraEventDeadLettersDAO { Mono<Event> retrieveFailedEvent(Group group, EventDeadLetters.InsertionId insertionId) { return executor.executeSingleRow(selectEventStatement.bind() .setString(GROUP, group.asString()) .setUUID(INSERTION_ID, insertionId.getId())) .map(row -> deserializeEvent(row.getString(EVENT))); } @Inject  CassandraEventDeadLettersDAO(Session session, EventSerializer eventSerializer);  }
CassandraEventDeadLettersDAO { Mono<Event> retrieveFailedEvent(Group group, EventDeadLetters.InsertionId insertionId) { return executor.executeSingleRow(selectEventStatement.bind() .setString(GROUP, group.asString()) .setUUID(INSERTION_ID, insertionId.getId())) .map(row -> deserializeEvent(row.getString(EVENT))); } @Inject  CassandraEventDeadLettersDAO(Session session, EventSerializer eventSerializer);   }