anchor.diff:                                  server_properties = [],
                                   locales = <<"en_US">>},
       ok = rabbit_writer:internal_send_command(Client, 0, Start, Protocol),
  -    handshake(State#state{protocol = Protocol, next = ?HEADER}).
  +    handshake(State#state{protocol = Protocol, stage = ?HEADER}).
   
   -spec decode(pos_integer(), binary(), rabbit_framing:protocol()) -> binary().
   %% @private
  
positive.code: 
  -include("include/amqpoxy.hrl").
  
  -record(state, {listener    :: pid(),
                  client      :: inet:socket(),
                  backend     :: undefined | inet:socket(),
                  proxy = ""  :: string(),
                  protocol    :: module(),
                  next        :: pos_integer(),
                  payload     :: undefined | {integer(), pos_integer()},
                  replay = [] :: [binary()]}).
  
  %% AMQP frame sizes
  -define(HANDSHAKE, 8).
  -define(HEADER, 7).
  
negative.code: %% @private
  init(Listener, Client, Opts) ->
      ok = cowboy:accept_ack(Listener),
      handshake(#state{client = Client,
                       proxy  = amqpoxy:format_ip(Opts),
                       stage  = ?HANDSHAKE}).
  
  %%
  %% Private
  