anchor.diff:      mover_manager:create_account_dets(),
   
       % Migrate
  -    R = proceed_migration(),
  +    R = proceed_migration(CallbackMod),
   
       % Reply with results
       process_results(R).
   
  -proceed_migration() ->
  -    proceed_migration(capture_org_state()).
  +proceed_migration(CallbackMod) ->
  +    proceed_migration(capture_org_state(CallbackMod), CallbackMod).
   
  -proceed_migration({ok, _}) ->
  -    migrate();
  -proceed_migration({error, Reason}) ->
  +proceed_migration({ok, _}, CallbackMod) ->
  +    migrate(CallbackMod);
  +proceed_migration({error, Reason}, _) ->
       {error, Reason, []}.
   
  -migrate() ->
  -    Orgs = org_list(),
  -    migrate_next(Orgs, []).
  +migrate(CallbackMod) ->
  +    Orgs = org_list(CallbackMod),
  +    migrate_next(Orgs, [], CallbackMod).
   
   process_results({error, Reason, CompletedOrgs}) ->
       [{status, {aborted, Reason}} | partition_results(CompletedOrgs)];
  
positive.code: 
  -export([ping/0,
           migrate_all/0,
           wait_for_status/0]).
  
  -define(POLL_SLEEP_MS, 500).
  
negative.code:     pong.
  
  migrate_all() ->
      migrate_all(mover_phase_1_migration_callback).
  
  migrate_all(CallbackMod) ->
      % Disable sleep  - for OPC migrations, we are guaranteed no in-flight traffic.
      application:set_env(mover, sleep_time, 0),
  
  