logger.warn("Failed to send {} to {}.", body, url, e);
            }
        }));
    }

    /**
     * Converts the discloser to a Slack message format.
     *
     * @param discloser the mail posting discloser
     * @return the formatted Slack message
     */
    protected String toSlackMessage(final SMailPostingDiscloser discloser) {
        final StringBuilder buf = new StringBuilder(100);

@Retention(RUNTIME)
@Documented
@Constraint(validatedBy = CronExpressionValidator.class)
public @interface CronExpression {

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

    /**
     * The validation groups this constraint belongs to.
     * @return the groups
     */

    }

    @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 {

                            PrintStream out = System.out;
                            for (String message = reader.readLine(); message != null; message = reader.readLine()) {
                                if (message.startsWith("  1> ")) {
                                    out = System.out;
                                } else if (message.startsWith("  2> ")) {
                                    out = System.err;

     * The abort flag is set to false by default.
     *
     * @param url the URL where the crawling error occurred
     * @param message the error message
     * @param cause the underlying exception that caused this error
     */
    public DataStoreCrawlingException(final String url, final String message, final Throwable cause) {

    /**
     * Constructs a new ConnectionTimeoutException with no detail message.
     */
    public ConnectionTimeoutException() {
    }

    /**
     * Constructs a new ConnectionTimeoutException with the specified detail message.
     * @param msg the detail message
     */
    public ConnectionTimeoutException(final String msg) {
        super(msg);
    }

    /**

   * Use this to monitor backpressure and avoid exceeding the 16 MiB outgoing message buffer limit.
   * When that limit is exceeded, the web socket is gracefully shut down.
   */
  fun queueSize(): Long

  /**
   * Attempts to enqueue `text` to be UTF-8 encoded and sent as a the data of a text (type `0x1`)
   * message.
   *
   * This method returns true if the message was enqueued. Messages that would overflow the outgoing

    /**
     * Constructs a new TransportException with no detail message.
     */
    public TransportException() {
    }

    /**
     * Constructs a new TransportException with the specified detail message.
     * @param msg the detail message
     */
    public TransportException(final String msg) {
        super(msg);
    }

    /**

     *
     * @param statusCode The HTTP status code
     * @param message The error message
     */
    public static void setError(final int statusCode, final String message) {
        LaRequestUtil.getOptionalRequest().ifPresent(req -> req.setAttribute(WEB_API_EXCEPTION, new WebApiException(statusCode, message)));
    }

    /**

    protected Object source;

    protected String longMessage;

    public AbstractMojoExecutionException(String message) {
        super(message);
    }

    public AbstractMojoExecutionException(String message, Throwable cause) {
        super(message, cause);
    }

    /**
     * Constructs a new {@code AbstractMojoExecutionException} exception wrapping an underlying {@code Throwable}.
     *