Spring/spring-boot-data-geode
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Refactor test case and setup to be more resilient to race conditions with Apache Geode/Pivotal GemFire CQ event delivery.

Browse Source
This commit is contained in:
John Blum
2018-08-15 12:58:30 -07:00
parent bcc32dc1a9
commit 4188f4381d
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-geode-autoconfigure/src/test/java/org/springframework/geode/boot/autoconfigure/cq/AutoConfiguredContinuousQueryIntegrationTests.java
View File

@@ -46,7 +46,7 @@ import org.springframework.data.gemfire.config.annotation.CacheServerApplication
import org.springframework.data.gemfire.config.annotation.EnableLogging;
import org.springframework.data.gemfire.config.annotation.EnablePdx;
import org.springframework.data.gemfire.tests.integration.ForkingClientServerIntegrationTestsSupport;
import org.springframework.data.gemfire.tests.integration.config.SubscriptionEnabledClientServerIntegrationTestsConfiguration;
import org.springframework.data.gemfire.tests.integration.config.ClientServerIntegrationTestsConfiguration;
import org.springframework.test.context.junit4.SpringRunner;
import example.geode.query.cq.event.TemperatureReading;
@@ -102,6 +102,9 @@ public class AutoConfiguredContinuousQueryIntegrationTests extends ForkingClient
.isEqualTo(TemperatureReading.of(99));
assertThat(this.temperatureReadings.sizeOnServer()).isEqualTo(8);
this.temperatureReadings.keySetOnServer().forEach(key ->
assertThat(this.temperatureReadings.get(key)).isNotEqualTo(0));
}
@Test
@@ -114,7 +117,8 @@ public class AutoConfiguredContinuousQueryIntegrationTests extends ForkingClient
@SpringBootApplication
@EnableLogging(logLevel = GEMFIRE_LOG_LEVEL)
@Import(SubscriptionEnabledClientServerIntegrationTestsConfiguration.class)
@Import(ClientServerIntegrationTestsConfiguration.class)
//@Import(SubscriptionEnabledClientServerIntegrationTestsConfiguration.class)
public static class GemFireClientConfiguration {
@Bean("TemperatureReadings")