anchor.diff:  frame(LogTuple) ->
       logplex_syslog_utils:frame(rfc5424(LogTuple)).
   
  -framing_fun() ->
  -    fun ({loss_indication, _N, _When}) ->
  -            skip;
  -        ({msg, MData}) ->
  -            {frame, frame(MData)}
  -    end.
  +drain_buf_framing({loss_indication, _N, _When}) ->
  +    skip;
  +drain_buf_framing({msg, MData}) ->
  +    {frame, frame(MData)}.
   
   -spec target_bytes() -> pos_integer().
   %% @private
  
positive.code:         ]).
  
  -export([user_agent/0
          ]).
  
  %% ------------------------------------------------------------------
  
negative.code:     case queue:out(Q) of
          {empty, Q} ->
              logplex_drain_buffer:set_active(Buf, target_bytes(),
                                              fun ?MODULE:drain_buf_framing/1),
              {next_state, connected, State};
          {{value, Frame}, Q2} ->
              try_send(Frame, State#state{out_q = Q2})
  