CassandraAttachmentMessageIdDAO { public Mono<Void> delete(AttachmentId attachmentId, MessageId ownerMessageId) { return cassandraAsyncExecutor.executeVoid( deleteStatement.bind() .setUUID(ATTACHMENT_ID_AS_UUID, attachmentId.asUUID()) .setString(MESSAGE_ID, ownerMessageId.serialize())); } @Inject  CassandraAttachmentMessageIdDAO(Session session, MessageId.Factory messageIdFactory); Flux<MessageId> getOwnerMessageIds(AttachmentId attachmentId); Mono<Void> storeAttachmentForMessageId(AttachmentId attachmentId, MessageId ownerMessageId); Mono<Void> delete(AttachmentId attachmentId, MessageId ownerMessageId);  }
@Test void deleteShouldNotThrowWhenNotExisting() { CassandraMessageId messageId1 = new CassandraMessageId.Factory().generate(); AttachmentId attachmentId = AttachmentId.random(); assertThatCode(() -> testee.delete(attachmentId, messageId1).block()) .doesNotThrowAnyException(); }