From cd28eb19a8a003bfe6b50b4c6c29649e4b017703 Mon Sep 17 00:00:00 2001 From: John Blum Date: Tue, 1 Dec 2020 10:46:59 -0800 Subject: [PATCH] Change signature of the generated AsyncEventQueue (AEQ) ID. 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. --- .../geode/cache/AsyncInlineCachingRegionConfigurer.java | 2 +- .../cache/AsyncInlineCachingRegionConfigurerUnitTests.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-geode/src/main/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurer.java b/spring-geode/src/main/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurer.java index 23922120..6b5dfb84 100644 --- a/spring-geode/src/main/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurer.java +++ b/spring-geode/src/main/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurer.java @@ -233,7 +233,7 @@ public class AsyncInlineCachingRegionConfigurer 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())); } /** diff --git a/spring-geode/src/test/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurerUnitTests.java b/spring-geode/src/test/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurerUnitTests.java index b14c1ab9..2e6c47d6 100644 --- a/spring-geode/src/test/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurerUnitTests.java +++ b/spring-geode/src/test/java/org/springframework/geode/cache/AsyncInlineCachingRegionConfigurerUnitTests.java @@ -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); }