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

Add mock support for CacheServer groups configuration.

Browse Source
This commit is contained in:
John Blum
2021-09-10 17:41:01 -07:00
parent 20e401e94f
commit ee16dd37ad
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java
View File

@@ -1112,9 +1112,14 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport {
AtomicReference<String> hostnameForClients = new AtomicReference<>(CacheServer.DEFAULT_HOSTNAME_FOR_CLIENTS);
AtomicReference<ServerLoadProbe> serverLoadProbe = new AtomicReference<>(null);
AtomicReference<String[]> groups = new AtomicReference<>(CacheServer.DEFAULT_GROUPS);
doAnswer(newSetter(bindAddress, () -> null))
.when(mockCacheServer).setBindAddress(anyString());
doAnswer(newSetter(groups, () -> null))
.when(mockCacheServer).setGroups(any(String[].class));
doAnswer(newSetter(hostnameForClients, () -> null))
.when(mockCacheServer).setHostnameForClients(anyString());
@@ -1154,6 +1159,7 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport {
when(mockCacheServer.getClientSession(any(DistributedMember.class)))
.thenThrow(newUnsupportedOperationException(NOT_SUPPORTED));
when(mockCacheServer.getClientSession(anyString())).thenThrow(newUnsupportedOperationException(NOT_SUPPORTED));
when(mockCacheServer.getGroups()).thenAnswer(newGetter(groups));
when(mockCacheServer.getHostnameForClients()).thenAnswer(newGetter(hostnameForClients));
when(mockCacheServer.getInterestRegistrationListeners()).thenReturn(Collections.emptySet());
when(mockCacheServer.getLoadPollInterval()).thenAnswer(newGetter(loadPollInterval));