return dstIndex - start;
        }

        /* The message provided to batch has a batchLimit that is
         * higher than the current batchLevel so we will now encode
         * that chained message. Before doing so we must increment
         * the batchLevel of the andx message in case it itself is an
         * andx message and needs to perform the same check as above.
         */

@Retention(RUNTIME)
@Documented
@Constraint(validatedBy = CustomSizeValidator.class)
public @interface CustomSize {

    /**
     * The error message when validation fails.
     * @return the error message
     */
    String message() default "{jakarta.validation.constraints.Size.message}";

    /**
     * The validation groups this constraint belongs to.
     * @return the groups
     */
    Class<?>[] groups() default {};

      "Code $code is reserved and may not be used."
    } else {
      null
    }

  fun validateCloseCode(code: Int) {
    val message = closeCodeExceptionMessage(code)
    require(message == null) { message!! }
  }

  fun acceptHeader(key: String): String = (key + ACCEPT_MAGIC).encodeUtf8().sha1().base64()

    private final int columnNumber;

    private final String message;

    private final Exception exception;

    private final Severity severity;

    /**
     * Creates a new problem with the specified message and exception.
     * Either {@code message} or {@code exception} is required
     *
     * @param message The message describing the problem, may be {@code null}.

     *
     * @return the protocol type
     */
    ProtocolType protocolType();

    /**
     * The validation error message.
     *
     * @return the error message
     */
    String message() default "{org.lastaflute.validator.constraints.UriType.message}";

    /**
     * The validation groups.
     *
     * @return the validation groups
     */
    Class<?>[] groups() default {};

    /**
     * Constructor.
     * @param message Exception message.
     * @param cause Root cause for this exception.
     */
    public ScheduledJobException(final String message, final Throwable cause) {
        super(message, cause);
    }

    /**
     * Constructor.
     * @param message Exception message.
     */
    public ScheduledJobException(final String message) {
        super(message);
    }

      if (overWaitUnits > 0) {
        message += overWaitUnits + " " + unitString;
        if (shouldShowExtraNanos) {
          message += ",";
        }
        message += " ";
      }
      if (shouldShowExtraNanos) {
        message += overWaitLeftoverNanos + " nanoseconds ";
      }

      message += "delay)";
    }

		}
		if errorResponse.Message != testCase.errorResponse.Message {
			t.Errorf("Test %d: %s: Expected the error message to be `%s`, but instead found `%s`", i+1, instanceType, testCase.errorResponse.Message, errorResponse.Message)
		}
		if errorResponse.Code != testCase.errorResponse.Code {

     * Creates a new DataStoreCrawlingException with the specified URL, message, and cause.
     * The abort flag is set to false by default.
     *
     * @param url the URL where the crawling error occurred
     * @param message the error message
     * @param e the underlying exception that caused this error
     */
    public DataStoreCrawlingException(final String url, final String message, final Exception e) {
        this(url, message, e, false);

    }

    @Override
    public String prompt(String message) throws PrompterException {
        try {
            return prompter.prompt(message, null, null);
        } catch (org.apache.maven.api.services.PrompterException e) {
            throw new PrompterException("Unable to prompt", e);
        }
    }

    @Override
    public String prompt(String message, String defaultReply) throws PrompterException {
        try {