import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
private TcpClientConfig createTcpClientConfig() {
  TcpClientConfig tcpClientConfig = new TcpClientConfig();
  DynamicLongProperty prop = AbstractTransport.getRequestTimeoutProperty();
  prop.addCallback(new Runnable() {
    public void run() {
      tcpClientConfig.setRequestTimeoutMillis(prop.get());
    }
  });
  tcpClientConfig.setRequestTimeoutMillis(prop.get());

  SSLOptionFactory factory =
      SSLOptionFactory.createSSLOptionFactory(SSL_KEY, null);
  SSLOption sslOption;
  if (factory == null) {
    sslOption = SSLOption.buildFromYaml(SSL_KEY);
  } else {
    sslOption = factory.createSSLOption();
  }
  SSLCustom sslCustom = SSLCustom.createSSLCustom(sslOption.getSslCustomClass());
  VertxTLSBuilder.buildClientOptionsBase(sslOption, sslCustom, tcpClientConfig);

  return tcpClientConfig;
}
 

import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
@Test
public void testDefaultHystrixCircuitBreakerUsed() throws InterruptedException {
    // Verify Hystrix config first
    DynamicLongProperty intervalInMilliseconds = DynamicPropertyFactory.getInstance()
            .getLongProperty("hystrix.command.default.metrics.healthSnapshot.intervalInMilliseconds", 500);
    assertEquals(intervalInMilliseconds.get(), 10);

    // CLOSED
    for (int i = 0; i < ShakyServiceClient.REQUEST_THRESHOLD; i++) {
        assertInvocation(false);
    }
    // Should be OPEN now
    HystrixCircuitBreaker breaker = HystrixCircuitBreaker.Factory.getInstance(HystrixCommandKey.Factory.asKey(getCommandKey()));
    assertNotNull(breaker);
    assertFalse(breaker.getClass().getName().contains("org.wildfly.swarm.microprofile.faulttolerance"));
    assertTrue(breaker.isOpen());
    assertInvocation(true);
    TimeUnit.MILLISECONDS.sleep(ShakyServiceClient.DELAY);
    // Should be HALF-OPEN
    assertInvocation(false);
    // OPEN again
    assertInvocation(true);
}
 

import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
public static DynamicLongProperty getRequestTimeoutProperty() {
  if (prop != null) {
    return prop;
  }

  prop = DynamicPropertyFactory.getInstance()
      .getLongProperty("cse.request.timeout", DEFAULT_TIMEOUT_MILLIS);
  return prop;
}
 

import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
public DynamicLongProperty getDynamicLongProperty(String name, long defaultValue) {
    DynamicLongProperty prop = (DynamicLongProperty) fastPropMap.get(name);
    if (prop != null) return prop;

    prop = DynamicPropertyFactory.getInstance().getLongProperty(name, defaultValue);
    fastPropMap.put(name, prop);
    return prop;
}
 

import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
@Override
public long getLongProperty(String propertyName, LongConsumer consumer, long defaultValue) {
  DynamicLongProperty prop = propertyFactoryInstance().getLongProperty(propertyName, defaultValue);
  prop.addCallback(() -> consumer.accept(prop.get()));
  return prop.get();
}
 

import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
public static long getServerTimeout() {
  DynamicLongProperty address =
      DynamicPropertyFactory.getInstance().getLongProperty("cse.rest.server.timeout", DEFAULT_TIMEOUT);
  return address.get();
}
 

import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
@Override
public long getLong(String key, long defaultValue, Runnable callback) {
    final DynamicLongProperty property = DynamicPropertyFactory.getInstance().getLongProperty(key, defaultValue, callback);
    return property.get();
}
 

import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
@Test
public void testBasicProperty() {
    DynamicLongProperty dynamicLongProperty = DynamicPropertyFactory.getInstance().getLongProperty("com.kixeye.platform.chassis.testLong", -1);
    assertEquals(42, dynamicLongProperty.get());
}
 

import com.netflix.config.DynamicLongProperty; //导入依赖的package包/类
public static DynamicLongProperty getLong(String key) {
    return DynamicPropertyFactory.getInstance().getLongProperty(key, 0);
}