) : InvocationHandler {
    /** Set when remote peer notifies ALPN is unsupported. */
    var unsupported: Boolean = false

    /** The protocol the server selected. */
    var selected: String? = null

    @Throws(Throwable::class)
    override fun invoke(
      proxy: Any,
      method: Method,
      args: Array<Any>?,
    ): Any? {
      val callArgs = args ?: arrayOf<Any?>()
      val methodName = method.name

            return null;
        }

        @Override
        public void log(String msg) {
        }

        @Override
        public void log(String message, Throwable throwable) {
        }

        @Override
        public String getServerInfo() {
            return null;
        }

        @Override
        public String getInitParameter(String name) {

       * pendingToString().)
       */
      CombinedFuture.this.task = null;

      setValue(result);
    }

    @Override
    final void afterRanInterruptiblyFailure(Throwable error) {
      // See afterRanInterruptiblySuccess.
      CombinedFuture.this.task = null;

      if (error instanceof ExecutionException) {
        /*

        verify(mockContext).withCredentials(creds);
    }

    @Test
    @DisplayName("Should renew credentials")
    void testRenewCredentials() {
        // Given
        String hint = "hint";
        Throwable error = new Exception();
        when(mockContext.renewCredentials(hint, error)).thenReturn(true);

        // When
        boolean renewed = mockContext.renewCredentials(hint, error);

        // Then

      notifyStopped();
    }
  }

  /** This is never thrown but only used for logging. */
  private static final class EmptyServiceManagerWarning extends Throwable {}

  private static final class FailedService extends Throwable {
    FailedService(Service service) {
      super(
          service.toString(),
          service.failureCause(),
          false /* don't enable suppression */,

            events.add(new LogNotificationEvent(((Number) source.get("timestamp")).longValue(), (String) source.get("level"),
                    (String) source.get("loggerName"), (String) source.get("message"), (String) source.get("throwable")));
            docIds.add(hit.getId());
        }

        final int maxDetailsLength = fessConfig.getLogNotificationMaxDetailsLengthAsInteger();

        assertTrue(exception instanceof FessSystemException);
        assertTrue(exception instanceof RuntimeException);
        assertTrue(exception instanceof Exception);
        assertTrue(exception instanceof Throwable);
    }

    @Test
    public void test_serializable() {
        // Test that the exception has serialVersionUID
        WebApiException exception = new WebApiException(404, "Not Found");

                        }
                    } catch (final CrawlingAccessException e) {
                        log(logHelper, LogType.CRAWLING_ACCESS_EXCEPTION, crawlerContext, urlQueue, e);
                    } catch (final Throwable e) {
                        log(logHelper, LogType.CRAWLING_EXCEPTION, crawlerContext, urlQueue, e);
                    } finally {
                        try {

                 * to return a proper ListenableFuture instead of using listenInPoolThread.
                 */
                getUninterruptibly(delegate);
              } catch (Throwable t) {
                // (including CancellationException and sneaky checked exception)
                // The task is presumably done, run the listeners.

        assertTrue(exception instanceof FessSystemException);
        assertTrue(exception instanceof RuntimeException);
        assertTrue(exception instanceof Exception);
        assertTrue(exception instanceof Throwable);
    }

    @Test
    public void test_serialVersionUID() {
        // Test that exception is serializable
        String message = "Serialization test";