SGF-410 - Enable the definition and creation of a generic, GemFire Cache Region with out-the-box defaults.
(cherry picked from commit d0ba11b3f3d53c03841fc732d2466083f9226881) Signed-off-by: John Blum <jblum@pivotal.io>
This commit is contained in:
John Blum
@@ -0,0 +1,183 @@
|
||||
/*
|
||||
* Copyright 2010-2013 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.data.gemfire;
|
||||
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertNotNull;
|
||||
|
||||
import org.junit.AfterClass;
|
||||
import org.junit.BeforeClass;
|
||||
import org.junit.Test;
|
||||
|
||||
import com.gemstone.gemfire.cache.Cache;
|
||||
import com.gemstone.gemfire.cache.CacheFactory;
|
||||
import com.gemstone.gemfire.cache.DataPolicy;
|
||||
import com.gemstone.gemfire.cache.Region;
|
||||
import com.gemstone.gemfire.cache.Scope;
|
||||
|
||||
/**
|
||||
* The GenericRegionFactoryBeanTest class is a test suite of test cases testing the contract and functionality
|
||||
* of the GenericRegionFactoryBean class.
|
||||
*
|
||||
* @author John Blum
|
||||
* @see org.springframework.data.gemfire.GenericRegionFactoryBean
|
||||
* @since 1.7.0
|
||||
*/
|
||||
public class GenericRegionFactoryBeanTest {
|
||||
|
||||
// as defined in the com.gemstone.gemfire.internal.cache.AbstractRegion class
|
||||
private static final Scope DEFAULT_SCOPE = Scope.DISTRIBUTED_NO_ACK;
|
||||
|
||||
private static Region<Object, Object> defaultRegion;
|
||||
private static Region<Object, Object> emptyRegion;
|
||||
private static Region<Object, Object> localRegion;
|
||||
private static Region<Object, Object> normalRegion;
|
||||
private static Region<Object, Object> persistentPartitionRegion;
|
||||
private static Region<Object, Object> preloadedRegion;
|
||||
private static Region<Object, Object> replicateRegion;
|
||||
|
||||
@BeforeClass
|
||||
public static void setup() throws Exception {
|
||||
Cache gemfireCache = new CacheFactory()
|
||||
.set("name", GenericRegionFactoryBeanTest.class.getSimpleName())
|
||||
.set("mcast-port", "0")
|
||||
.set("log-level", "warning")
|
||||
.create();
|
||||
|
||||
RegionFactoryBean<Object, Object> defaultRegionFactory = new GenericRegionFactoryBean<Object, Object>();
|
||||
defaultRegionFactory.setCache(gemfireCache);
|
||||
defaultRegionFactory.setName("DefaultRegion");
|
||||
defaultRegionFactory.afterPropertiesSet();
|
||||
|
||||
defaultRegion = defaultRegionFactory.getObject();
|
||||
|
||||
RegionFactoryBean<Object, Object> emptyRegionFactory = new GenericRegionFactoryBean<Object, Object>();
|
||||
emptyRegionFactory.setCache(gemfireCache);
|
||||
emptyRegionFactory.setDataPolicy(DataPolicy.EMPTY);
|
||||
emptyRegionFactory.setName("EmptyRegion");
|
||||
emptyRegionFactory.setScope(Scope.DISTRIBUTED_NO_ACK);
|
||||
emptyRegionFactory.afterPropertiesSet();
|
||||
|
||||
emptyRegion = emptyRegionFactory.getObject();
|
||||
|
||||
RegionFactoryBean<Object, Object> localRegionFactory = new GenericRegionFactoryBean<Object, Object>();
|
||||
localRegionFactory.setCache(gemfireCache);
|
||||
localRegionFactory.setDataPolicy(DataPolicy.NORMAL);
|
||||
localRegionFactory.setName("LocalRegion");
|
||||
localRegionFactory.setScope(Scope.LOCAL);
|
||||
localRegionFactory.afterPropertiesSet();
|
||||
|
||||
localRegion = localRegionFactory.getObject();
|
||||
|
||||
RegionFactoryBean<Object, Object> normalRegionFactory = new GenericRegionFactoryBean<Object, Object>();
|
||||
normalRegionFactory.setCache(gemfireCache);
|
||||
normalRegionFactory.setDataPolicy(DataPolicy.NORMAL);
|
||||
normalRegionFactory.setName("NormalRegion");
|
||||
normalRegionFactory.setScope(Scope.DISTRIBUTED_ACK);
|
||||
normalRegionFactory.afterPropertiesSet();
|
||||
|
||||
normalRegion = normalRegionFactory.getObject();
|
||||
|
||||
RegionFactoryBean<Object, Object> persistentPartitionRegionFactory = new GenericRegionFactoryBean<Object, Object>();
|
||||
persistentPartitionRegionFactory.setCache(gemfireCache);
|
||||
persistentPartitionRegionFactory.setDataPolicy(DataPolicy.PERSISTENT_PARTITION);
|
||||
persistentPartitionRegionFactory.setName("PersistentPartitionRegion");
|
||||
persistentPartitionRegionFactory.setPersistent(true);
|
||||
persistentPartitionRegionFactory.afterPropertiesSet();
|
||||
|
||||
persistentPartitionRegion = persistentPartitionRegionFactory.getObject();
|
||||
|
||||
RegionFactoryBean<Object, Object> preloadedRegionFactory = new GenericRegionFactoryBean<Object, Object>();
|
||||
preloadedRegionFactory.setCache(gemfireCache);
|
||||
preloadedRegionFactory.setDataPolicy(DataPolicy.PRELOADED);
|
||||
preloadedRegionFactory.setName("PreloadedRegion");
|
||||
preloadedRegionFactory.afterPropertiesSet();
|
||||
|
||||
preloadedRegion = preloadedRegionFactory.getObject();
|
||||
|
||||
RegionFactoryBean<Object, Object> replicateRegionFactory = new GenericRegionFactoryBean<Object, Object>();
|
||||
replicateRegionFactory.setCache(gemfireCache);
|
||||
replicateRegionFactory.setDataPolicy(DataPolicy.REPLICATE);
|
||||
replicateRegionFactory.setName("ReplicateRegion");
|
||||
replicateRegionFactory.setScope(Scope.GLOBAL);
|
||||
replicateRegionFactory.afterPropertiesSet();
|
||||
|
||||
replicateRegion = replicateRegionFactory.getObject();
|
||||
}
|
||||
|
||||
@AfterClass
|
||||
public static void tearDown() {
|
||||
try {
|
||||
CacheFactory.getAnyInstance().close();
|
||||
}
|
||||
catch (Exception ignore) {
|
||||
}
|
||||
}
|
||||
|
||||
protected void assertRegionAttributes(Region<?, ?> region, String expectedRegionName, DataPolicy expectedDataPolicy,
|
||||
Scope expectedScope) {
|
||||
assertRegionAttributes(region, expectedRegionName, String.format("%1$s%2$s", Region.SEPARATOR, expectedRegionName),
|
||||
expectedDataPolicy, expectedScope);
|
||||
}
|
||||
|
||||
protected void assertRegionAttributes(Region<?, ?> region, String expectedRegionName, String expectedRegionPath,
|
||||
DataPolicy expectedDataPolicy, Scope expectedScope) {
|
||||
assertNotNull("The GemFire Cache Region must not be null!", region);
|
||||
assertEquals(expectedRegionName, region.getName());
|
||||
assertEquals(expectedRegionPath, region.getFullPath());
|
||||
assertNotNull("The RegionAttributes must be specified!", region.getAttributes());
|
||||
assertEquals(expectedDataPolicy, region.getAttributes().getDataPolicy());
|
||||
assertEquals(expectedScope, region.getAttributes().getScope());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void defaultRegionAttributes() {
|
||||
assertRegionAttributes(defaultRegion, "DefaultRegion", DataPolicy.DEFAULT, DEFAULT_SCOPE);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void emptyRegionAttributes() {
|
||||
assertRegionAttributes(emptyRegion, "EmptyRegion", DataPolicy.EMPTY, Scope.DISTRIBUTED_NO_ACK);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void localRegionAttributes() {
|
||||
assertRegionAttributes(localRegion, "LocalRegion", DataPolicy.NORMAL, Scope.LOCAL);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void normalRegionAttributes() {
|
||||
assertRegionAttributes(normalRegion, "NormalRegion", DataPolicy.NORMAL, Scope.DISTRIBUTED_ACK);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void persistentPartitionRegionAttributes() {
|
||||
assertRegionAttributes(persistentPartitionRegion, "PersistentPartitionRegion", DataPolicy.PERSISTENT_PARTITION,
|
||||
DEFAULT_SCOPE);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void preloadedRegionAttributes() {
|
||||
assertRegionAttributes(preloadedRegion, "PreloadedRegion", DataPolicy.PRELOADED, DEFAULT_SCOPE);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void replicateRegionAttributes() {
|
||||
assertRegionAttributes(replicateRegion, "ReplicateRegion", DataPolicy.REPLICATE, Scope.GLOBAL);
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user