anchor.diff:              {noreply, reconnect(tcp_error, State)}
       end;
   
  -handle_cast(Msg, State) ->
  -    ?WARN("Unexpected cast ~p", [Msg]),
  -    {noreply, State}.
  -
  -%% @private
   handle_info(?RECONNECT_MSG, State = #state{sock = undefined}) ->
       State1 = State#state{tref = undefined},
       case connect(State1) of
  
positive.code: 
  %% @private
  init([State0 = #state{id=ID, channel=Chan}]) ->
      DrainSize = logplex_app:config(tcp_drain_buffer_size),
      {ok, State0#state{buf = logplex_drain_buffer:new(DrainSize)}}.
  
  %% @private
  handle_call(Call, _From, State) ->
  
negative.code:     {noreply, State}.
  
  %% @private
  handle_cast(Msg, State) ->
      ?WARN("Unexpected cast ~p", [Msg]),
      {noreply, State}.
  
  %% @private
  handle_info({post, Msg}, State = #state{sock=undefined,
                                          buf=Buf}) ->
      NewBuf = logplex_drain_buffer:push(Msg, Buf),
      {noreply, State#state{buf=NewBuf}};
  
  handle_info({post, Msg}, State = #state{id = Token,
                                          sock = S}) ->
      case post(Msg, S, Token) of
          ok ->
  