覆盖 .properties 文件中指定的 Hystrix 命令属性

Question

我需要覆盖我的 application.properties 文件中指定的命令超时属性。这是我尝试过的

    @Test
    public void testTokenQueryTimeout() throws Exception
    {
      String propertyToSet ="hystrix.command.quickbaseTokenQueryCommand.execution.isolation.thread.timeoutInMilliseconds";
      String prop="";
      try {
        prop = ConfigurationManager.getConfigInstance().getProperty(
            propertyToSet).toString();
        logger.info("\n\n\noriginal quickbaseTokenQueryCommand timeout ="+prop);

        System.setProperty(
            propertyToSet,"10");

        prop = ConfigurationManager.getConfigInstance().getProperty(
            propertyToSet).toString();
        logger.info("\n\n\nupdated quickbaseTokenQueryCommand timeout ="+prop);

        String response = accountValidation.isValidToken(token);
        logger.info(response);
        Assert.assertFalse(true);
      }
      catch (AccountValidationServiceException e)
      {
        Assert.assertTrue(Constants.ERRCODE_TOKEN_QUERY_TIMED_OUT.equals(e.getErrorCode()));
      }
      finally {
        ConfigurationManager.getConfigInstance().clearProperty(propertyToSet);
        System.clearProperty(propertyToSet);
        if(!GeneralUtil.isObjectEmpty(System.getProperty(
            propertyToSet)))prop = System.getProperty(
            propertyToSet);

        logger.info("Updated testTokenQueryTimeout timeout ="+prop);
      }
    }

注意，System.setProperty(propertyToSet,"10")。使用这种方法，这个测试用例通过了，即属性被更改并且命令超时，但是另一个测试用例由于这个命令超时而失败，尽管我正在从系统中清除属性。

我还尝试使用 ConfigurationManager.getConfigInstance().setProperty( propertyToSet).toString(),"10");但是在那种情况下，这个属性的改变是没有效果的，命令也不会超时。

这里有什么我遗漏的吗？

请帮忙。

Answer 1

尝试使用 ConcurrentCompositeConfiguration 类

application.properties

hystrix.command.HelloWorldCommand.execution.isolation.thread.timeoutInMilliseconds=200

命令

public class HelloWorldCommand extends HystrixCommand<String> {

  public HelloWorldCommand() {
    super(HystrixCommandGroupKey.Factory.asKey("HelloWorldGroup"));
  }

  @Override
  protected String run() throws Exception {
    TimeUnit.MILLISECONDS.sleep(1100);
    return "Hello";
  }
}

测试

public class HelloWorldCommandTest {

  @Test
  public void commandConfigTest() {
    String propertyKey = "hystrix.command.HelloWorldCommand.execution.isolation.thread.timeoutInMilliseconds";
    ConcurrentCompositeConfiguration config = (ConcurrentCompositeConfiguration) ConfigurationManager.getConfigInstance();

    Integer originalTimeout = (Integer) config.getProperty(propertyKey);
    config.setOverrideProperty(propertyKey, 1200);
    String result = new HelloWorldCommand().execute();
    assertThat(result, is("Hello"));

    config.setOverrideProperty(propertyKey, originalTimeout);
    Integer timeoutValue = (Integer) config.getProperty(propertyKey);
    assertThat(timeoutValue, is(originalTimeout));
  }
}