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

Modify AsyncInlineCachingRegionConfigurer to append to the list of AEQs registered on the Region when configuring Async, Inline Caching.

Browse Source
This commit is contained in:
John Blum
2020-09-18 16:46:47 -07:00
parent da073b8ef3
commit 8abf6687d2
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -219,8 +219,7 @@ public class AsyncInlineCachingRegionConfigurer<T, ID> implements RegionConfigur
AsyncEventQueue queue = newAsyncEventQueue((Cache) bean.getCache(), beanName);
// TODO: change; PeerRegionFactoryBean.setAsyncEventQueues(..) overwrites the existing user-configured AEQs.
bean.setAsyncEventQueues(ArrayUtils.asArray(queue));
bean.addAsyncEventQueues(ArrayUtils.asArray(queue));
}
}

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

@@ -242,7 +242,7 @@ public class AsyncInlineCachingRegionConfigurerUnitTests {
verify(regionConfigurer, times(1))
.newAsyncEventQueue(eq(mockCache), eq("TestRegion"));
verify(peerRegionFactoryBean, times(1))
.setAsyncEventQueues(eq(ArrayUtils.asArray(mockAsyncEventQueue)));
.addAsyncEventQueues(eq(ArrayUtils.asArray(mockAsyncEventQueue)));
verifyNoMoreInteractions(regionConfigurer, peerRegionFactoryBean);
verifyNoInteractions(mockAsyncEventQueue, mockCache, mockRepository);