def process_email(self, rfc822_email, email_id, epoch):
    try:
        self._set_email_id_contains(email_id)
    except Exception:
        pass
    (ret_val, message, results) = self._int_process_email(rfc822_email, email_id, epoch)
    if (not ret_val):
        return (phantom.APP_ERROR, message)
    self._parse_results(results)
    return (phantom.APP_SUCCESS, PROC_EMAIL_PROCESSED)
def process_email(self, rfc822_email, email_id, epoch):
    try:
        self._set_email_id_contains(email_id)
    except Exception:
        pass
    (ret_val, message, results) = self._int_process_email(rfc822_email, email_id, epoch)
    if (not ret_val):
        return (phantom.APP_ERROR, message)
    self._parse_results(results)
    return (phantom.APP_SUCCESS, PROC_EMAIL_PROCESSED)