try {
            suggestJob.executeSuggestCreator();
            // In test environment, exception handling may vary
        } catch (JobProcessingException e) {
            assertTrue(e.getMessage().contains("SuggestCreator Process terminated"));
        } catch (Exception e) {
            // May throw different exception in test environment
            assertNotNull(e);
        }
    }

    LogRecord record = Iterables.getOnlyElement(logHandler.getStoredLogRecords());
    // We log failures that occur after startup
    assertThat(record.getMessage())
        .contains("Service FailRunService [FAILED] has failed in the RUNNING state");
  }

  /**
   * Tests that a ServiceManager can be fully shut down if one of its failure listeners is slow or

            } catch (final UnknownHostException ex) {
                this.uhe = ex;
            } catch (final Exception ex) {
                this.uhe = new UnknownHostException(ex.getMessage());
            } finally {
                synchronized (this.sem) {
                    this.sem.count--;
                    this.sem.notify();
                }
            }
        }

            fail("Expected JobProcessingException to be thrown");
        } catch (final JobProcessingException e) {
            assertEquals("test error", e.getMessage());
        }
    }

    /**
     * Test that generic exceptions are caught and null is returned
     */
    @Test
    public void test_evaluate_genericExceptionReturnsNull() {

            fail("Should throw FessSystemException");
        } catch (FessSystemException e) {
            assertEquals("DataService is null. IndexUpdater cannot proceed without a DataService instance.", e.getMessage());
        }
    }

    // Test run method basic flow
    @Test
    public void test_run_basicFlow() throws Exception {
        final List<String> sessionIdList = Arrays.asList("session1");

    ImmutableMap<Object, ImmutableSet<Object>> tmpMap;
    try {
      tmpMap = builder.buildOrThrow();
    } catch (IllegalArgumentException e) {
      throw (InvalidObjectException) new InvalidObjectException(e.getMessage()).initCause(e);
    }

    deserializationReplacement = new ImmutableSetMultimap<>(tmpMap, tmpSize, valueComparator);
  }

  @GwtIncompatible
  @J2ktIncompatible
    private Object readResolve() {

    ImmutableMap<Object, ImmutableSet<Object>> tmpMap;
    try {
      tmpMap = builder.buildOrThrow();
    } catch (IllegalArgumentException e) {
      throw (InvalidObjectException) new InvalidObjectException(e.getMessage()).initCause(e);
    }

    deserializationReplacement = new ImmutableSetMultimap<>(tmpMap, tmpSize, valueComparator);
  }

  @GwtIncompatible
  @J2ktIncompatible
    private Object readResolve() {

    private volatile boolean serviceAvailable = true;
    
    public void handleServiceUnavailable(Exception error) {
        log.warn("Witness service unavailable: {}", error.getMessage());
        serviceAvailable = false;
        
        // Schedule retry
        scheduleServiceRetry();
    }
    
    private void scheduleServiceRetry() {
        scheduler.schedule(() -> {

        try {
            helper.completeOperation("nonexistent_operation");
        } catch (final Exception e) {
            fail("completeOperation should not throw: " + e.getMessage());
        }
    }

    @Test
    public void test_completeOperation_doubleCall_safe() {
        // Calling completeOperation twice must not throw (idempotent release)

            Relocation target, Relocation source, boolean sourceDominant, Map<Object, Object> context) {
        String src = source.getMessage();
        if (src != null) {
            if (sourceDominant || target.getMessage() == null) {
                target.setMessage(src);
                target.setLocation("message", source.getLocation("message"));
            }
        }
    }