* that enqueued messages were not transmitted.
   */
  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
   * message buffer will be rejected and trigger a [graceful shutdown][close] of this web socket.

interface LoggerAdapter {

    boolean isFatalEnabled();

    void fatal(String message);

    void fatal(String message, Throwable t);

    boolean isErrorEnabled();

    void error(String message);

    void error(String message, Throwable t);

    boolean isWarnEnabled();

    void warn(String message);

    void warn(String message, Throwable t);

    boolean isInfoEnabled();

    void info(String message);

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

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

    public ModelInterpolationException(String expression, String message, Throwable cause) {
        super("The POM expression: " + expression + " could not be evaluated. Reason: " + message, cause);

        this.expression = expression;

public class DataStoreException extends FessSystemException {
    private static final long serialVersionUID = 1L;

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

    public DataStoreException(final String message) {
        super(message);
    }

    public DataStoreException(final Throwable cause) {
        super(cause);
    }

    public JobProcessingException(final Throwable e) {
        super(e);
    }

    public JobProcessingException(final String message, final Throwable e) {
        super(message, e);
    }

    public JobProcessingException(final String message) {
        super(message);
    }

    private static final long serialVersionUID = 1L;

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

    public DictionaryException(final String message) {
        super(message);
    }

    private static final long serialVersionUID = 1L;

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

    public MimeTypeException(final String message) {
        super(message);
    }

    public MimeTypeException(final Throwable cause) {
        super(cause);
    }

                    message.length(), &forward_op);
  ASSERT_EQ(errors::OK, s.code()) << s.message();
  int num_retvals = 1;
  std::vector<AbstractTensorHandle*> outputs(1);
  GradientRegistry registry;
  s = RegisterGradients(&registry);
  ASSERT_EQ(errors::OK, s.code()) << s.message();
  auto tape = std::make_unique<Tape>(/*persistent=*/false);

     * @param cause The cause of the problem, may be {@code null}.
     */
    void add(Problem.Severity severity, String message, int line, int column, Exception cause);

    /**
     * The next messages will be bound to this source. When calling this method again, previous messages keep
     * their source, but the next messages will use the new source.
     *
     * @param source a source
     */
    void setSource(String source);

    }

    /**
     * @param message a message
     * @param cause a cause
     * @deprecated use {@link #ArtifactMetadataRetrievalException(String, Throwable, Artifact)}
     */
    @Deprecated
    public ArtifactMetadataRetrievalException(String message, Throwable cause) {
        this(message, cause, null);
    }

    public ArtifactMetadataRetrievalException(String message, Throwable cause, Artifact artifact) {