From fbf7a26787763aba4c236ce8e57e3f6c0127150b Mon Sep 17 00:00:00 2001 From: fishtailfu Date: Thu, 17 Jul 2025 11:05:18 +0800 Subject: [PATCH] fix: fix ConfigChangeListener ut bug --- .../polaris/config/listener/ConfigChangeListenerTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/spring-cloud-starter-tencent-polaris-config/src/test/java/com/tencent/cloud/polaris/config/listener/ConfigChangeListenerTest.java b/spring-cloud-starter-tencent-polaris-config/src/test/java/com/tencent/cloud/polaris/config/listener/ConfigChangeListenerTest.java index 6898bb331..5a445e5c7 100644 --- a/spring-cloud-starter-tencent-polaris-config/src/test/java/com/tencent/cloud/polaris/config/listener/ConfigChangeListenerTest.java +++ b/spring-cloud-starter-tencent-polaris-config/src/test/java/com/tencent/cloud/polaris/config/listener/ConfigChangeListenerTest.java @@ -57,7 +57,7 @@ import static org.springframework.boot.test.context.SpringBootTest.WebEnvironmen }) public class ConfigChangeListenerTest { - private static final CountDownLatch hits = new CountDownLatch(2); + private static CountDownLatch hits = new CountDownLatch(2); @Autowired private ApplicationEventPublisher applicationEventPublisher; @Autowired @@ -85,13 +85,16 @@ public class ConfigChangeListenerTest { Set ketSet = new HashSet<>(); ketSet.add("timeout"); for (int i = 2; i <= 1000; i++) { + // Reset hits for each iteration //submit change event System.setProperty("timeout", String.valueOf(i * 1000)); EnvironmentChangeEvent event = new EnvironmentChangeEvent(applicationContext, ketSet); applicationEventPublisher.publishEvent(event); + //after change boolean ret = hits.await(2, TimeUnit.SECONDS); Assertions.assertThat(ret).isEqualTo(true); + hits = new CountDownLatch(2); Assertions.assertThat(testConfig.getChangeCnt()).isEqualTo(2 * i - 2); Assertions.assertThat(testConfig.getSyncChangeCnt()).isEqualTo(2 * i - 2); Assertions.assertThat(testConfig.getTimeout()).isEqualTo(i * 1000);