@Test void deleteShouldNotThrowWhenRowDoesntExist() { testee.delete(messageIdFactory.of(UUIDs.timeBased()), CassandraId.timeBased()) .block(); }
public Mono<Void> delete(CassandraMessageId messageId, CassandraId mailboxId) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MESSAGE_ID, messageId.get()) .setUUID(MAILBOX_ID, mailboxId.asUuid())); }
CassandraMessageIdToImapUidDAO { public Mono<Void> delete(CassandraMessageId messageId, CassandraId mailboxId) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MESSAGE_ID, messageId.get()) .setUUID(MAILBOX_ID, mailboxId.asUuid())); } }
CassandraMessageIdToImapUidDAO { public Mono<Void> delete(CassandraMessageId messageId, CassandraId mailboxId) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MESSAGE_ID, messageId.get()) .setUUID(MAILBOX_ID, mailboxId.asUuid())); } @Inject  CassandraMessageIdToImapUidDAO(Session session, CassandraConsistenciesConfiguration consistenciesConfiguration,
                                          CassandraMessageId.Factory messageIdFactory); }
CassandraMessageIdToImapUidDAO { public Mono<Void> delete(CassandraMessageId messageId, CassandraId mailboxId) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MESSAGE_ID, messageId.get()) .setUUID(MAILBOX_ID, mailboxId.asUuid())); } @Inject  CassandraMessageIdToImapUidDAO(Session session, CassandraConsistenciesConfiguration consistenciesConfiguration,
                                          CassandraMessageId.Factory messageIdFactory); Mono<Void> delete(CassandraMessageId messageId, CassandraId mailboxId); Mono<Void> insert(ComposedMessageIdWithMetaData composedMessageIdWithMetaData); Mono<Boolean> updateMetadata(ComposedMessageIdWithMetaData composedMessageIdWithMetaData, ModSeq oldModSeq); Flux<ComposedMessageIdWithMetaData> retrieve(CassandraMessageId messageId, Optional<CassandraId> mailboxId); Flux<ComposedMessageIdWithMetaData> retrieveAllMessages(); }
CassandraMessageIdToImapUidDAO { public Mono<Void> delete(CassandraMessageId messageId, CassandraId mailboxId) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MESSAGE_ID, messageId.get()) .setUUID(MAILBOX_ID, mailboxId.asUuid())); } @Inject  CassandraMessageIdToImapUidDAO(Session session, CassandraConsistenciesConfiguration consistenciesConfiguration,
                                          CassandraMessageId.Factory messageIdFactory); Mono<Void> delete(CassandraMessageId messageId, CassandraId mailboxId); Mono<Void> insert(ComposedMessageIdWithMetaData composedMessageIdWithMetaData); Mono<Boolean> updateMetadata(ComposedMessageIdWithMetaData composedMessageIdWithMetaData, ModSeq oldModSeq); Flux<ComposedMessageIdWithMetaData> retrieve(CassandraMessageId messageId, Optional<CassandraId> mailboxId); Flux<ComposedMessageIdWithMetaData> retrieveAllMessages();  }