Skip to content
This repository has been archived by the owner on Jan 5, 2022. It is now read-only.

Commit

Permalink
Renames listener to complete.
Browse files Browse the repository at this point in the history
  • Loading branch information
Todd Nine committed Mar 6, 2015
1 parent 275e74a commit dc87edc
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 8 deletions.
Expand Up @@ -22,10 +22,7 @@


import org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyV2Impl; import org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyV2Impl;
import org.apache.usergrid.persistence.collection.serialization.impl.migration.CollectionMigrationPlugin; import org.apache.usergrid.persistence.collection.serialization.impl.migration.CollectionMigrationPlugin;
import org.apache.usergrid.persistence.collection.serialization.impl.migration.EntityIdScope;
import org.apache.usergrid.persistence.core.migration.data.MigrationInfoSerialization; import org.apache.usergrid.persistence.core.migration.data.MigrationInfoSerialization;
import org.apache.usergrid.persistence.core.migration.data.DataMigration;
import org.apache.usergrid.persistence.core.migration.data.MigrationDataProvider;
import org.apache.usergrid.persistence.core.migration.data.MigrationPlugin; import org.apache.usergrid.persistence.core.migration.data.MigrationPlugin;
import org.apache.usergrid.persistence.core.migration.data.PluginPhase; import org.apache.usergrid.persistence.core.migration.data.PluginPhase;
import org.apache.usergrid.persistence.core.migration.data.ProgressObserver; import org.apache.usergrid.persistence.core.migration.data.ProgressObserver;
Expand Down Expand Up @@ -110,7 +107,7 @@ public void run( final ProgressObserver observer ) {
//save the version //save the version
migrationInfoSerialization.setVersion( NAME, getMaxVersion() ); migrationInfoSerialization.setVersion( NAME, getMaxVersion() );


observer.stop(); observer.complete();
} }




Expand Down
Expand Up @@ -118,7 +118,7 @@ private boolean runMigration( final ProgressObserver po ) {
//write the version //write the version
migrationInfoSerialization.setVersion( getName(), newSystemVersion ); migrationInfoSerialization.setVersion( getName(), newSystemVersion );


po.stop(); po.complete();


//signal we've run a migration and return //signal we've run a migration and return
return true; return true;
Expand Down
Expand Up @@ -194,7 +194,7 @@ public void start() {




@Override @Override
public void stop() { public void complete() {
migrationInfoSerialization.setStatusCode( pluginName, StatusCode.COMPLETE.status ); migrationInfoSerialization.setStatusCode( pluginName, StatusCode.COMPLETE.status );
} }


Expand Down
Expand Up @@ -34,7 +34,7 @@ public interface ProgressObserver {
/** /**
* Signal the process has stopped * Signal the process has stopped
*/ */
public void stop(); public void complete();


/** /**
* Mark the migration as failed * Mark the migration as failed
Expand Down
Expand Up @@ -41,7 +41,7 @@ public void start() {




@Override @Override
public void stop() { public void complete() {
started = false; started = false;
} }


Expand Down

0 comments on commit dc87edc

Please sign in to comment.