assertTrue(foundTestMethod);
    }

    public void test_throwAndCatch() {
        // Test throwing and catching the exception
        String expectedMessage = "Offset limit exceeded: 10000";

        try {
            throw new ResultOffsetExceededException(expectedMessage);
        } catch (ResultOffsetExceededException e) {
            assertEquals(expectedMessage, e.getMessage());
            assertNull(e.getCause());

  fun play() {
    serverSocket = ServerSocket(0)
    executor.execute {
      val threadName = "SocksProxy ${serverSocket!!.localPort}"
      Thread.currentThread().name = threadName
      try {
        while (true) {
          val socket = serverSocket!!.accept()
          connectionCount.incrementAndGet()
          service(socket)
        }
      } catch (e: SocketException) {

        verifyCrudMode(form.crudMode, CrudMode.CREATE);
        validate(form, messages -> {}, this::asEditHtml);
        verifyToken(this::asEditHtml);
        getRelatedContent(form).ifPresent(entity -> {
            try {
                relatedContentService.store(entity);
                saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL));
            } catch (final Exception e) {

                return new Properties();
            }
        };

        try {
            emptyEnv.get("non.existent.property");
            fail("Should throw ConfigPropertyNotFoundException");
        } catch (ConfigPropertyNotFoundException e) {
            assertTrue(e.getMessage().contains("non.existent.property"));
        }

        try {
            emptyEnv.is("non.existent.boolean");

      @JvmStatic
      fun isAlpnBootEnabled(): Boolean =
        try {
          Class.forName("org.eclipse.jetty.alpn.ALPN", true, null)
          true
        } catch (cnfe: ClassNotFoundException) {
          false
        }

      val isCorrettoSupported: Boolean =
        try {
          // Trigger an early exception over a fatal error, prefer a RuntimeException over Error.

              future.cancel(true);
              if (!future.isDone()) {
                errorMessage.set("Cancel call exited before future was complete.");
              }
            }
          });
      try {
        future.get();
      } catch (Throwable t) {
        // Ignore, we just wanted to block.
      }
      String error = errorMessage.get();
      assertNull(error, error);
    }

    var random: String? = null
    lateinit var currentThread: Thread

    private val loggerHandler =
      object : Handler() {
        override fun publish(record: LogRecord) {
          // Try to avoid multi threading issues with concurrent requests
          if (Thread.currentThread() != currentThread) {
            return
          }

      field.setAccessible(true);
    }

    void set(T instance, Object value) {
      try {
        field.set(instance, value);
      } catch (IllegalAccessException impossible) {
        throw new AssertionError(impossible);
      }
    }

    void set(T instance, int value) {
      try {
        field.set(instance, value);
      } catch (IllegalAccessException impossible) {

                dictionaryPath = fessConfig.getIndexDictionaryPrefix() + "/" + path;
            } else {
                dictionaryPath = path;
            }
            try {
                source = FileUtil.readUTF8(filePath);
                try (CurlResponse response =
                        ComponentUtil.getCurlHelper().post("/_configsync/file").param("path", dictionaryPath).body(source).execute()) {

    }

    public void test_getJobExecutor_withSuffix() {
        try {
            ComponentUtil.getJobExecutor("testJobExecutor");
            fail("Should throw exception");
        } catch (Exception e) {
            // Expected
        }
    }

    public void test_getJobExecutor_withoutSuffix() {
        try {
            ComponentUtil.getJobExecutor("test");