@Test void updateShouldNotFailWhenMailboxIsAbsent() { testee.updatePath(CASSANDRA_ID_1, NEW_MAILBOX_PATH).block(); }
public Mono<Void> updatePath(CassandraId mailboxId, MailboxPath mailboxPath) { return executor.executeVoid(updateStatement.bind() .setUUID(ID, mailboxId.asUuid()) .setString(NAME, mailboxPath.getName()) .setUDTValue(MAILBOX_BASE, mailboxBaseTupleUtil.createMailboxBaseUDT(mailboxPath.getNamespace(), mailboxPath.getUser()))); }
CassandraMailboxDAO { public Mono<Void> updatePath(CassandraId mailboxId, MailboxPath mailboxPath) { return executor.executeVoid(updateStatement.bind() .setUUID(ID, mailboxId.asUuid()) .setString(NAME, mailboxPath.getName()) .setUDTValue(MAILBOX_BASE, mailboxBaseTupleUtil.createMailboxBaseUDT(mailboxPath.getNamespace(), mailboxPath.getUser()))); } }
CassandraMailboxDAO { public Mono<Void> updatePath(CassandraId mailboxId, MailboxPath mailboxPath) { return executor.executeVoid(updateStatement.bind() .setUUID(ID, mailboxId.asUuid()) .setString(NAME, mailboxPath.getName()) .setUDTValue(MAILBOX_BASE, mailboxBaseTupleUtil.createMailboxBaseUDT(mailboxPath.getNamespace(), mailboxPath.getUser()))); } @Inject  CassandraMailboxDAO(Session session, CassandraTypesProvider typesProvider,
                               CassandraConsistenciesConfiguration consistenciesConfiguration,
                               CassandraUtils cassandraUtils); @VisibleForTesting  CassandraMailboxDAO(Session session, CassandraTypesProvider typesProvider,
                               CassandraConsistenciesConfiguration consistenciesConfiguration); }
CassandraMailboxDAO { public Mono<Void> updatePath(CassandraId mailboxId, MailboxPath mailboxPath) { return executor.executeVoid(updateStatement.bind() .setUUID(ID, mailboxId.asUuid()) .setString(NAME, mailboxPath.getName()) .setUDTValue(MAILBOX_BASE, mailboxBaseTupleUtil.createMailboxBaseUDT(mailboxPath.getNamespace(), mailboxPath.getUser()))); } @Inject  CassandraMailboxDAO(Session session, CassandraTypesProvider typesProvider,
                               CassandraConsistenciesConfiguration consistenciesConfiguration,
                               CassandraUtils cassandraUtils); @VisibleForTesting  CassandraMailboxDAO(Session session, CassandraTypesProvider typesProvider,
                               CassandraConsistenciesConfiguration consistenciesConfiguration); Mono<Void> save(Mailbox mailbox); Mono<Void> updatePath(CassandraId mailboxId, MailboxPath mailboxPath); Mono<Void> delete(CassandraId mailboxId); Mono<Mailbox> retrieveMailbox(CassandraId mailboxId); Flux<Mailbox> retrieveAllMailboxes(); }
CassandraMailboxDAO { public Mono<Void> updatePath(CassandraId mailboxId, MailboxPath mailboxPath) { return executor.executeVoid(updateStatement.bind() .setUUID(ID, mailboxId.asUuid()) .setString(NAME, mailboxPath.getName()) .setUDTValue(MAILBOX_BASE, mailboxBaseTupleUtil.createMailboxBaseUDT(mailboxPath.getNamespace(), mailboxPath.getUser()))); } @Inject  CassandraMailboxDAO(Session session, CassandraTypesProvider typesProvider,
                               CassandraConsistenciesConfiguration consistenciesConfiguration,
                               CassandraUtils cassandraUtils); @VisibleForTesting  CassandraMailboxDAO(Session session, CassandraTypesProvider typesProvider,
                               CassandraConsistenciesConfiguration consistenciesConfiguration); Mono<Void> save(Mailbox mailbox); Mono<Void> updatePath(CassandraId mailboxId, MailboxPath mailboxPath); Mono<Void> delete(CassandraId mailboxId); Mono<Mailbox> retrieveMailbox(CassandraId mailboxId); Flux<Mailbox> retrieveAllMailboxes();  }