anchor.diff:              Token = logplex_token:new(Id, Ch, Name),
               {ok, Token}
       end.
  +
  +%% Loads tokens without indexing them. Can only be used by rdb-load
  +%% routines and must be followed by a logplex_token:reindex_tokens().
  +load_token(Id, Dict) ->
  +    case find_token(Id, Dict) of
  +        {error, missing_channel} ->
  +            ?ERR("~p ~p ~p ~p",
  +                 [create_token, missing_ch, Id, dict:to_list(Dict)]);
  +        {ok, Token} ->
  +            logplex_token:load(Token),
               Token
       end.
   
  
positive.code: 
  handle({load, <<"tok:", Rest/binary>>, Dict}) when is_tuple(Dict) ->
      Id = parse_id(Rest),
      create_token(Id, Dict);
  
  handle({load, <<"drain:", Rest/binary>>, Dict}) when is_tuple(Dict) ->
      Id = drain_id(parse_id(Rest)),
  
negative.code: 
  handle({load, eof}) ->
      ?INFO("at=nsync_load_complete", []),
      {Time, Result} = timer:tc(fun logplex_token:reindex_tokens/0),
      Tokens = logplex_token:num_records(),
      ?INFO("at=tokens_reindexed time=~pus records=~p result=~p",
            [Time, Tokens, Result]),
      error_logger:info_msg("NSYNC sync complete"),
      application:set_env(logplex, nsync_loaded, true),
      ok;
  