anchor.diff:  -module(nsync_callback).
   -export([handle/1]).
   
  --include_lib("logplex.hrl").
  +-include("logplex.hrl").
  +-include("logplex_logging.hrl").
  +
   
   %% nsync callbacks
   
  
positive.code: populate_token_channel_data([Token|Tail]) when is_record(Token, token) ->
      case logplex_channel:lookup(Token#token.channel_id) of
          undefined ->
              io:format("Error ~p ~p ~p ~p~n", [?MODULE, populate_token_channel_data, undefined_channel, Token]);
          #channel{app_id=AppId} ->
              ets:insert(tokens, Token#token{app_id=AppId})
      end,
  
negative.code:                     Tcp = (dict_find(<<"tcp">>, Dict) =/= <<"false">>),
                      case Tcp of
                          true ->
                              logplex_drain:start(tcpsyslog, Token,
                                                  [Ch, Token, Host, Port]);
                          _ ->
                              ?ERR("no udp support for ~p ~p ~p:~p~n",
                                   [Ch, Token, Host, Port])
                      end,
                      Drain = #drain{
                          id=Id,
  