anchor.diff:  peername(Socket) ->
       case inet:peername(Socket) of
           {ok, {Ip, Port}} -> amqpoxy:format_ip(Ip, Port);
  -        _Error           -> disconnected
  +        _Error           -> 'DISCONNECT'
       end.
  
positive.code: %% @private
  forward(Match = {login, Login}, State = #state{client = Client}) ->
      Routed = State#state{backend = amqpoxy_router:match(Match)},
      log(io_lib:fwrite("ROUTE <~s>", [Login]), Routed),
      Replayed = replay(Routed),
      ok = inet:setopts(Client, [{active, true}]),
      proxy(Replayed).
  
negative.code:             ok = gen_tcp:send(Client, Data),
              proxy(State);
          {tcp_closed, Client} ->
              log("CLIENT", State),
              gen_tcp:close(Backend),
              ok;
          {tcp_closed, Backend}->
              log("SERVER", State),
              gen_tcp:close(Client),
              ok
      end.
  