anchor.diff:                          BinToken, Payload, Msg#apns_msg.priority) of
           ok ->
             {noreply, State#state{out_expires = Timeout}};
  -      {error, Reason} ->
  +      {error, Reason} -> 
           apns_queue:fail(State#state.queue, Msg#apns_msg.id),
           {stop, {error, Reason}, State}
       end
  
positive.code:       case Command of
          8 -> %% Error
            Status = parse_status(StatusCode),
            {_MsgFailed, RestMsg} = apns_queue:fail(State#state.queue, MsgId),
            [send_message(self(), M) || M <- RestMsg],
            try call(Error, [MsgId, Status]) of
              stop -> throw({stop, {msg_error, MsgId, Status}, State});
  
negative.code:       {noreply, state()} | {stop, ssl_closed | {unknown_request, X}, state()}.
  handle_info( {ssl, SslSocket, Data}
             , State = #state{ out_socket = SslSocket
                             , connection = #apns_connection{error_fun = Error, feedback_fun = DeleteSubscription}
                             , out_buffer = CurrentBuffer
                             , error_logger_fun = ErrorLoggerFun
                             , name = Name
  