anchor.diff:  
   handle({load, <<"tok:", Rest/binary>>, Dict}) when is_tuple(Dict) ->
       Id = parse_id(Rest),
  -    create_token(Id, Dict);
  +    load_token(Id, Dict);
   
   handle({load, <<"drain:", Rest/binary>>, Dict}) when is_tuple(Dict) ->
       Id = drain_id(parse_id(Rest)),
  
positive.code: 
  handle({load, eof}) ->
      ?INFO("at=nsync_load_complete", []),
      error_logger:info_msg("NSYNC sync complete"),
      application:set_env(logplex, nsync_loaded, true),
      ok;
  
negative.code:             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.
  
  