@Test void emptyMigrationShouldSucceed() throws InterruptedException { assertThat(migration.asTask().run()).isEqualTo(Task.Result.COMPLETED); }
@Override public Task asTask() { return new MappingsSourcesMigrationTask(this); }
MappingsSourcesMigration implements Migration { @Override public Task asTask() { return new MappingsSourcesMigrationTask(this); } }
MappingsSourcesMigration implements Migration { @Override public Task asTask() { return new MappingsSourcesMigrationTask(this); } @Inject  MappingsSourcesMigration(CassandraRecipientRewriteTableDAO cassandraRecipientRewriteTableDAO,
                                    CassandraMappingsSourcesDAO cassandraMappingsSourcesDAO); }
MappingsSourcesMigration implements Migration { @Override public Task asTask() { return new MappingsSourcesMigrationTask(this); } @Inject  MappingsSourcesMigration(CassandraRecipientRewriteTableDAO cassandraRecipientRewriteTableDAO,
                                    CassandraMappingsSourcesDAO cassandraMappingsSourcesDAO); @Override void apply(); @Override Task asTask(); }
MappingsSourcesMigration implements Migration { @Override public Task asTask() { return new MappingsSourcesMigrationTask(this); } @Inject  MappingsSourcesMigration(CassandraRecipientRewriteTableDAO cassandraRecipientRewriteTableDAO,
                                    CassandraMappingsSourcesDAO cassandraMappingsSourcesDAO); @Override void apply(); @Override Task asTask(); static final TaskType TYPE; }