anchor.diff:      end),
       {noreply, State};
   
  -handle_info(_Info, State) ->
  +handle_info(Msg, State) ->
  +    ?WARN("err=unexpected_info data=~p", [Msg]),
       {noreply, State}.
   
   terminate(_Reason, _State) ->
  
positive.code:             {stop, Error}
      end.
  
  handle_call(_Msg, _From, State) ->
      {reply, {error, invalid_call}, State}.
  
  handle_cast(_Msg, State) ->
      io:format("realtime: recv'd ~p~n", [_Msg]),
      {noreply, State}.
  
  handle_info(flush, #state{instance_name=undefined}=State) ->
  
negative.code:                 opts,
                  conn}).
  
  -include("logplex.hrl").
  -include("logplex_logging.hrl").
  
  %% API functions
  start_link(Opts) ->
  