ExecutorHealthChecker { public void checkExecutorHealthQuietly() { try { logger.info("Begin executor healthcheck routine."); checkExecutorHealth(); } catch (final RuntimeException e) { logger.error("Unexepected error during executor healthcheck.", e); } finally { logger.info("End executor healthcheck routine."); } } @Inject  ExecutorHealthChecker(final Props azkProps, final ExecutorLoader executorLoader,
      final ExecutorApiGateway apiGateway, final AlerterHolder alerterHolder); void start(); void shutdown(); void checkExecutorHealthQuietly();  }
@Test public void testCheckExecutorHealthWrapperExceptionHandling() throws Exception { this.activeFlows.put(EXECUTION_ID_11, new Pair<>( new ExecutionReference(EXECUTION_ID_11, this.executor1), this.flow1)); when(this.apiGateway.callWithExecutionId(this.executor1.getHost(), this.executor1.getPort(), ConnectorParams.PING_ACTION, null, null)).thenThrow(new RuntimeException("test exception")); this.executorHealthChecker.checkExecutorHealthQuietly(); verifyZeroInteractions(this.alerterHolder); }