anchor.diff:      ready_to_send(State);
   connected(Msg, State) ->
       ?WARN("drain_id=~p channel_id=~p dest=~s err=unexpected_info "
  -          "data=~10000p state=connected",
  +          "data=\"~1000p\" state=connected",
             log_info(State, [Msg])),
       {next_state, connected, State}.
   
   %% @private
   handle_event(Event, StateName, State) ->
  -    ?WARN("state=~p at=unexpected_event event=~10000p",
  +    ?WARN("state=~p at=unexpected_event event=\"~1000p\"",
             [StateName, Event]),
       {next_state, StateName, State}.
   
  
positive.code:     try_connect(cancel_reconnect(push_frame(Frame, MsgCount, State)));
  disconnected(Msg, State) ->
      ?WARN("drain_id=~p channel_id=~p dest=~s err=unexpected_info "
            "data=~1000p state=disconnected",
            log_info(State, [Msg])),
      {next_state, disconnected, State}.
  
  
negative.code:     logplex_drain_buffer:notify(Buf),
      {reply, ok, StateName, State};
  handle_sync_event(Event, _From, StateName, State) ->
      ?WARN("state=~p at=unexpected_sync_event event=\"~1000p\"",
            [StateName, Event]),
      {next_state, StateName, State}.
  
  