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

Change signature of the generated AsyncEventQueue (AEQ) ID.

Browse Source 
This fixes a bug that manifests through GemFire/Geode's Management infrastructure, specifically with the MBean's ObjectName used to managed the AEQs across the cluster.
This commit is contained in:
John Blum
2020-12-01 10:46:59 -08:00
parent 27c907336a
commit cd28eb19a8
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-geode/src/main/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurer.java vendored
View File

@@ -233,7 +233,7 @@ public class AsyncInlineCachingRegionConfigurer<T, ID> implements RegionConfigur
Assert.hasText(regionBeanName, () -> String.format("Region bean name [%s] must be specified", regionBeanName));
return regionBeanName.concat(String.format("-AEQ:%s", UUID.randomUUID().toString()));
return regionBeanName.concat(String.format("-AEQ-%s", UUID.randomUUID().toString()));
}
/**

2
spring-geode/src/test/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurerUnitTests.java vendored
View File

@@ -278,7 +278,7 @@ public class AsyncInlineCachingRegionConfigurerUnitTests {
AsyncInlineCachingRegionConfigurer<?, ?> regionConfigurer =
new AsyncInlineCachingRegionConfigurer<>(mockRepository, Predicate.isEqual("TestRegion"));
assertThat(regionConfigurer.generateId("MockRegion")).startsWith("MockRegion-AEQ:");
assertThat(regionConfigurer.generateId("MockRegion")).startsWith("MockRegion-AEQ-");
verifyNoInteractions(mockRepository);
}