diff --git a/spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java b/spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java index 8c13f3b..2404633 100644 --- a/spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java +++ b/spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/mock/GemFireMockObjectsSupport.java @@ -3096,112 +3096,148 @@ public abstract class GemFireMockObjectsSupport extends MockObjectsSupport { new ExpirationAttributes(0, ExpirationAction.INVALIDATE); AtomicBoolean cloningEnabled = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getCloningEnabled).orElse(false)); + .map(RegionAttributes::getCloningEnabled) + .orElse(false)); AtomicBoolean concurrencyChecksEnabled = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getConcurrencyChecksEnabled).orElse(true)); + .map(RegionAttributes::getConcurrencyChecksEnabled) + .orElse(true)); AtomicBoolean diskSynchronous = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::isDiskSynchronous).orElse(true)); + .map(RegionAttributes::isDiskSynchronous) + .orElse(true)); AtomicBoolean enableAsyncConflation = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getEnableAsyncConflation).orElse(false)); + .map(RegionAttributes::getEnableAsyncConflation) + .orElse(false)); AtomicBoolean enableSubscriptionConflation = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getEnableSubscriptionConflation).orElse(false)); + .map(RegionAttributes::getEnableSubscriptionConflation) + .orElse(false)); AtomicBoolean ignoreJta = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getIgnoreJTA).orElse(false)); + .map(RegionAttributes::getIgnoreJTA) + .orElse(false)); AtomicBoolean indexMaintenanceSynchronous = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getIndexMaintenanceSynchronous).orElse(true)); + .map(RegionAttributes::getIndexMaintenanceSynchronous) + .orElse(true)); AtomicBoolean lockGrantor = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::isLockGrantor).orElse(false)); + .map(RegionAttributes::isLockGrantor) + .orElse(false)); AtomicBoolean multicastEnabled = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getMulticastEnabled).orElse(false)); + .map(RegionAttributes::getMulticastEnabled) + .orElse(false)); AtomicBoolean offHeap = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getOffHeap).orElse(false)); + .map(RegionAttributes::getOffHeap) + .orElse(false)); AtomicBoolean statisticsEnabled = new AtomicBoolean(optionalRegionAttributes - .map(RegionAttributes::getStatisticsEnabled).orElse(false)); + .map(RegionAttributes::getStatisticsEnabled) + .orElse(false)); AtomicInteger concurrencyLevel = new AtomicInteger(optionalRegionAttributes - .map(RegionAttributes::getConcurrencyLevel).orElse(16)); + .map(RegionAttributes::getConcurrencyLevel) + .orElse(16)); AtomicInteger initialCapacity = new AtomicInteger(optionalRegionAttributes - .map(RegionAttributes::getInitialCapacity).orElse(16)); + .map(RegionAttributes::getInitialCapacity) + .orElse(16)); AtomicReference cacheLoader = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getCacheLoader).orElse(null)); + .map(RegionAttributes::getCacheLoader) + .orElse(null)); AtomicReference cacheWriter = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getCacheWriter).orElse(null)); + .map(RegionAttributes::getCacheWriter) + .orElse(null)); AtomicReference compressor = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getCompressor).orElse(null)); + .map(RegionAttributes::getCompressor) + .orElse(null)); AtomicReference> customEntryIdleTimeout = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getCustomEntryIdleTimeout).orElse(null)); + .map(RegionAttributes::getCustomEntryIdleTimeout) + .orElse(null)); AtomicReference> customEntryTimeToLive = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getCustomEntryTimeToLive).orElse(null)); + .map(RegionAttributes::getCustomEntryTimeToLive) + .orElse(null)); AtomicReference dataPolicy = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getDataPolicy).orElseGet(() -> convert(regionShortcut))); + .map(RegionAttributes::getDataPolicy) + .orElseGet(() -> convert(regionShortcut))); AtomicReference diskStoreName = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getDiskStoreName).orElse(null)); + .map(RegionAttributes::getDiskStoreName) + .orElse(null)); AtomicReference entryIdleTimeout = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getEntryIdleTimeout).orElse(DEFAULT_EXPIRATION_ATTRIBUTES)); + .map(RegionAttributes::getEntryIdleTimeout) + .orElse(DEFAULT_EXPIRATION_ATTRIBUTES)); AtomicReference entryTimeToLive = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getEntryTimeToLive).orElse(DEFAULT_EXPIRATION_ATTRIBUTES)); + .map(RegionAttributes::getEntryTimeToLive) + .orElse(DEFAULT_EXPIRATION_ATTRIBUTES)); AtomicReference evictionAttributes = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getEvictionAttributes).orElseGet(EvictionAttributes::createLRUEntryAttributes)); + .map(RegionAttributes::getEvictionAttributes) + .orElseGet(EvictionAttributes::createLRUEntryAttributes)); AtomicReference> keyConstraint = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getKeyConstraint).orElse(null)); + .map(RegionAttributes::getKeyConstraint) + .orElse(null)); AtomicReference loadFactor = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getLoadFactor).orElse(0.75f)); + .map(RegionAttributes::getLoadFactor) + .orElse(0.75f)); AtomicReference membershipAttributes = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getMembershipAttributes).orElseGet(MembershipAttributes::new)); + .map(RegionAttributes::getMembershipAttributes) + .orElseGet(MembershipAttributes::new)); AtomicReference> partitionAttributes = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getPartitionAttributes).orElse(null)); + .map(RegionAttributes::getPartitionAttributes) + .orElse(null)); AtomicReference poolName = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getPoolName).orElse(null)); + .map(RegionAttributes::getPoolName) + .orElse(null)); AtomicReference regionIdleTimeout = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getRegionIdleTimeout).orElse(DEFAULT_EXPIRATION_ATTRIBUTES)); + .map(RegionAttributes::getRegionIdleTimeout) + .orElse(DEFAULT_EXPIRATION_ATTRIBUTES)); AtomicReference regionTimeToLive = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getRegionTimeToLive).orElse(DEFAULT_EXPIRATION_ATTRIBUTES)); + .map(RegionAttributes::getRegionTimeToLive) + .orElse(DEFAULT_EXPIRATION_ATTRIBUTES)); AtomicReference scope = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getScope).orElse(Scope.DISTRIBUTED_NO_ACK)); + .map(RegionAttributes::getScope) + .orElse(Scope.DISTRIBUTED_NO_ACK)); AtomicReference subscriptionAttributes = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getSubscriptionAttributes).orElseGet(SubscriptionAttributes::new)); + .map(RegionAttributes::getSubscriptionAttributes) + .orElseGet(SubscriptionAttributes::new)); AtomicReference> valueConstraint = new AtomicReference<>(optionalRegionAttributes - .map(RegionAttributes::getValueConstraint).orElse(null)); + .map(RegionAttributes::getValueConstraint) + .orElse(null)); List cacheListeners = new ArrayList<>(Arrays.asList(nullSafeArray(optionalRegionAttributes - .map(RegionAttributes::getCacheListeners).orElse(null), CacheListener.class))); + .map(RegionAttributes::getCacheListeners) + .orElse(null), CacheListener.class))); Set asyncEventQueueIds = new HashSet<>(nullSafeSet(optionalRegionAttributes - .map(RegionAttributes::getAsyncEventQueueIds).orElse(null))); + .map(RegionAttributes::getAsyncEventQueueIds) + .orElse(null))); Set gatewaySenderIds = new HashSet<>(nullSafeSet(optionalRegionAttributes - .map(RegionAttributes::getGatewaySenderIds).orElse(null))); + .map(RegionAttributes::getGatewaySenderIds) + .orElse(null))); when(mockRegionFactory.addAsyncEventQueueId(anyString())) .thenAnswer(newAdder(asyncEventQueueIds, mockRegionFactory));