@Test void deleteShouldNotThrowWhenRowDoesntExist() { testee.delete(CassandraId.timeBased(), MessageUid.of(1)) .block(); }
public Mono<Void> delete(CassandraId mailboxId, MessageUid uid) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MAILBOX_ID, mailboxId.asUuid()) .setLong(IMAP_UID, uid.asLong())); }
CassandraMessageIdDAO { public Mono<Void> delete(CassandraId mailboxId, MessageUid uid) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MAILBOX_ID, mailboxId.asUuid()) .setLong(IMAP_UID, uid.asLong())); } }
CassandraMessageIdDAO { public Mono<Void> delete(CassandraId mailboxId, MessageUid uid) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MAILBOX_ID, mailboxId.asUuid()) .setLong(IMAP_UID, uid.asLong())); } @Inject  CassandraMessageIdDAO(Session session, CassandraMessageId.Factory messageIdFactory); }
CassandraMessageIdDAO { public Mono<Void> delete(CassandraId mailboxId, MessageUid uid) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MAILBOX_ID, mailboxId.asUuid()) .setLong(IMAP_UID, uid.asLong())); } @Inject  CassandraMessageIdDAO(Session session, CassandraMessageId.Factory messageIdFactory); Mono<Void> delete(CassandraId mailboxId, MessageUid uid); Mono<Void> insert(ComposedMessageIdWithMetaData composedMessageIdWithMetaData); Mono<Void> updateMetadata(ComposedMessageIdWithMetaData composedMessageIdWithMetaData); Mono<Optional<ComposedMessageIdWithMetaData>> retrieve(CassandraId mailboxId, MessageUid uid); Flux<ComposedMessageIdWithMetaData> retrieveMessages(CassandraId mailboxId, MessageRange set, Limit limit); Flux<ComposedMessageIdWithMetaData> retrieveAllMessages(); }
CassandraMessageIdDAO { public Mono<Void> delete(CassandraId mailboxId, MessageUid uid) { return cassandraAsyncExecutor.executeVoid(delete.bind() .setUUID(MAILBOX_ID, mailboxId.asUuid()) .setLong(IMAP_UID, uid.asLong())); } @Inject  CassandraMessageIdDAO(Session session, CassandraMessageId.Factory messageIdFactory); Mono<Void> delete(CassandraId mailboxId, MessageUid uid); Mono<Void> insert(ComposedMessageIdWithMetaData composedMessageIdWithMetaData); Mono<Void> updateMetadata(ComposedMessageIdWithMetaData composedMessageIdWithMetaData); Mono<Optional<ComposedMessageIdWithMetaData>> retrieve(CassandraId mailboxId, MessageUid uid); Flux<ComposedMessageIdWithMetaData> retrieveMessages(CassandraId mailboxId, MessageRange set, Limit limit); Flux<ComposedMessageIdWithMetaData> retrieveAllMessages(); static final String LIMIT; }