Skip to content

Commit 95a67f6

Browse files
committed
Add mock support for MembershipAttributes configuration on RegionAttributes for a Region.
1 parent fc98bd0 commit 95a67f6

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

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

+9
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,7 @@
9999
import org.apache.geode.cache.ExpirationAttributes;
100100
import org.apache.geode.cache.GemFireCache;
101101
import org.apache.geode.cache.LoaderHelper;
102+
import org.apache.geode.cache.MembershipAttributes;
102103
import org.apache.geode.cache.PartitionAttributes;
103104
import org.apache.geode.cache.Region;
104105
import org.apache.geode.cache.RegionAttributes;
@@ -203,6 +204,7 @@
203204
* @see org.apache.geode.cache.EvictionAttributesMutator
204205
* @see org.apache.geode.cache.ExpirationAttributes
205206
* @see org.apache.geode.cache.GemFireCache
207+
* @see org.apache.geode.cache.MembershipAttributes
206208
* @see org.apache.geode.cache.PartitionAttributes
207209
* @see org.apache.geode.cache.Region
208210
* @see org.apache.geode.cache.RegionAttributes
@@ -2730,6 +2732,7 @@ private static <K, V> RegionAttributes<K, V> mockRegionAttributes(Region<K, V> m
27302732
when(mockRegionAttributes.getInitialCapacity()).thenAnswer(newGetter(baseRegionAttributes::getInitialCapacity));
27312733
when(mockRegionAttributes.getKeyConstraint()).thenAnswer(newGetter(baseRegionAttributes::getKeyConstraint));
27322734
when(mockRegionAttributes.getLoadFactor()).thenAnswer(newGetter(baseRegionAttributes::getLoadFactor));
2735+
when(mockRegionAttributes.getMembershipAttributes()).thenAnswer(newGetter(baseRegionAttributes::getMembershipAttributes));
27332736
when(mockRegionAttributes.getMulticastEnabled()).thenAnswer(newGetter(baseRegionAttributes::getMulticastEnabled));
27342737
when(mockRegionAttributes.getOffHeap()).thenAnswer(newGetter(baseRegionAttributes::getOffHeap));
27352738
when(mockRegionAttributes.getPartitionAttributes()).thenAnswer(newGetter(baseRegionAttributes::getPartitionAttributes));
@@ -3167,6 +3170,8 @@ public static <K, V> RegionFactory<K, V> mockRegionFactory(Cache mockCache, Regi
31673170
AtomicReference<Float> loadFactor = new AtomicReference<>(optionalRegionAttributes
31683171
.map(RegionAttributes::getLoadFactor).orElse(0.75f));
31693172

3173+
AtomicReference<MembershipAttributes> membershipAttributes = new AtomicReference<>(new MembershipAttributes());
3174+
31703175
AtomicReference<PartitionAttributes<K, V>> partitionAttributes = new AtomicReference<>(optionalRegionAttributes
31713176
.map(RegionAttributes::getPartitionAttributes).orElse(null));
31723177

@@ -3274,6 +3279,9 @@ public static <K, V> RegionFactory<K, V> mockRegionFactory(Cache mockCache, Regi
32743279

32753280
when(mockRegionFactory.setLockGrantor(anyBoolean())).thenAnswer(newSetter(lockGrantor, mockRegionFactory));
32763281

3282+
when(mockRegionFactory.setMembershipAttributes(any(MembershipAttributes.class)))
3283+
.thenAnswer(newSetter(membershipAttributes, () -> mockRegionFactory));
3284+
32773285
when(mockRegionFactory.setMulticastEnabled(anyBoolean()))
32783286
.thenAnswer(newSetter(multicastEnabled, mockRegionFactory));
32793287

@@ -3332,6 +3340,7 @@ public static <K, V> RegionFactory<K, V> mockRegionFactory(Cache mockCache, Regi
33323340
when(mockRegionAttributes.getKeyConstraint()).thenAnswer(newGetter(keyConstraint));
33333341
when(mockRegionAttributes.getLoadFactor()).thenAnswer(newGetter(loadFactor));
33343342
when(mockRegionAttributes.isLockGrantor()).thenAnswer(newGetter(lockGrantor));
3343+
when(mockRegionAttributes.getMembershipAttributes()).thenAnswer(newGetter(membershipAttributes));
33353344
when(mockRegionAttributes.getMulticastEnabled()).thenAnswer(newGetter(multicastEnabled));
33363345
when(mockRegionAttributes.getOffHeap()).thenAnswer(newGetter(offHeap));
33373346
when(mockRegionAttributes.getPartitionAttributes()).thenAnswer(newGetter(partitionAttributes));

0 commit comments

Comments
 (0)