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

Add mock configuration for the peer Cache gatewayConflictResolver object property.

Browse Source
This commit is contained in:
John Blum
2021-09-08 15:14:38 -07:00
parent 6889b3c696
commit 395d55ae1d
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -138,6 +138,7 @@ import org.apache.geode.cache.query.types.ObjectType;
import org.apache.geode.cache.server.CacheServer;
import org.apache.geode.cache.server.ClientSubscriptionConfig;
import org.apache.geode.cache.server.ServerLoadProbe;
import org.apache.geode.cache.util.GatewayConflictResolver;
import org.apache.geode.cache.wan.GatewayEventFilter;
import org.apache.geode.cache.wan.GatewayEventSubstitutionFilter;
import org.apache.geode.cache.wan.GatewayReceiver;
@@ -869,6 +870,8 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport {
AtomicInteger messageSyncInterval = new AtomicInteger();
AtomicInteger searchTimeout = new AtomicInteger();
AtomicReference<GatewayConflictResolver> gatewayConflictResolver = new AtomicReference<>();
List<CacheServer> cacheServers = new ArrayList<>();
when(mockCache.addCacheServer()).thenAnswer(invocation -> {
@@ -880,6 +883,9 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport {
return mockCacheServer;
});
doAnswer(newSetter(gatewayConflictResolver, () -> null))
.when(mockCache).setGatewayConflictResolver(any(GatewayConflictResolver.class));
doAnswer(newSetter(lockLease, null)).when(mockCache).setLockLease(anyInt());
doAnswer(newSetter(lockTimeout, null)).when(mockCache).setLockTimeout(anyInt());
doAnswer(newSetter(messageSyncInterval, null)).when(mockCache).setMessageSyncInterval(anyInt());
@@ -889,6 +895,7 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport {
when(mockCache.getAsyncEventQueues())
.thenAnswer(invocation -> Collections.unmodifiableSet(new HashSet<>(asyncEventQueues.values())));
when(mockCache.getCacheServers()).thenAnswer(invocation -> Collections.unmodifiableList(cacheServers));
when(mockCache.getGatewayConflictResolver()).thenAnswer(newGetter(gatewayConflictResolver));
when(mockCache.getGatewayReceivers()).thenAnswer(invocation -> Collections.unmodifiableSet(gatewayReceivers));
when(mockCache.getGatewaySenders())
.thenAnswer(invocation -> Collections.unmodifiableSet(new HashSet<>(gatewaySenders.values())));