class MailboxPathV2Migration implements Migration {

    @Override
    public void apply() {
        daoV1.readAll()
            .flatMap(this::migrate)
            .doOnError(t -> LOGGER.error("Error while performing migration", t))
            .blockLast();
    }

    @Inject public  MailboxPathV2Migration(CassandraMailboxPathDAOImpl daoV1, CassandraMailboxPathV2DAO daoV2);

}