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

Fixes JIRA bug SGF-312 allowing developers to declare/define and register multiple PartitionListeners on a Partitioned Region using nested inner bean and bean reference elements inside the <gfe:partition-listener> sub-element of the <gfe:partitioned-region> element in the SDG XML namespace (XSD).

Browse Source 
(cherry picked from commit b9a966e11a)

Signed-off-by: John Blum <jblum@pivotal.io>
This commit is contained in:
John Blum
2014-08-27 23:08:39 -07:00
committed by John Blum
parent c46b5f8575
commit f1e5fee45b
6 changed files with 225 additions and 111 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/main/java/org/springframework/data/gemfire/PartitionAttributesFactoryBean.java
View File

@@ -27,23 +27,24 @@ import com.gemstone.gemfire.cache.PartitionResolver;
import com.gemstone.gemfire.cache.partition.PartitionListener;
/**
* Spring-friendly bean for creating {@link PartitionAttributes}. Eliminates the
* need of using a XML 'factory-method' tag and allows the attributes properties
* to be set directly.
* Spring-friendly bean for creating {@link PartitionAttributes}. Eliminates the need of using
* a XML 'factory-method' tag and allows the attributes properties to be set directly.
*
* @author Costin Leau
* @author David Turanski
* @author John Blum
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
@SuppressWarnings({ "rawtypes", "unchecked", "unused" })
public class PartitionAttributesFactoryBean implements FactoryBean<PartitionAttributes>, InitializingBean {
private final com.gemstone.gemfire.cache.PartitionAttributesFactory paf = new com.gemstone.gemfire.cache.PartitionAttributesFactory();
private final com.gemstone.gemfire.cache.PartitionAttributesFactory partitionAttributesFactory =
new com.gemstone.gemfire.cache.PartitionAttributesFactory();
private List<PartitionListener> listeners;
@Override
public PartitionAttributes getObject() throws Exception {
return paf.create();
return partitionAttributesFactory.create();
}
@Override
@@ -57,21 +58,21 @@ public class PartitionAttributesFactoryBean implements FactoryBean<PartitionAttr
}
public void setColocatedWith(String colocatedRegionFullPath) {
paf.setColocatedWith(colocatedRegionFullPath);
partitionAttributesFactory.setColocatedWith(colocatedRegionFullPath);
}
public void setFixedPartitionAttributes(List<FixedPartitionAttributes> fixedPartitionAttributes) {
for (FixedPartitionAttributes fpa : fixedPartitionAttributes) {
paf.addFixedPartitionAttributes(fpa);
partitionAttributesFactory.addFixedPartitionAttributes(fpa);
}
}
public void setLocalMaxMemory(int mb) {
paf.setLocalMaxMemory(mb);
partitionAttributesFactory.setLocalMaxMemory(mb);
}
public void setPartitionResolver(PartitionResolver resolver) {
paf.setPartitionResolver(resolver);
partitionAttributesFactory.setPartitionResolver(resolver);
}
public void setPartitionListeners(List<PartitionListener> listeners) {
@@ -79,32 +80,33 @@ public class PartitionAttributesFactoryBean implements FactoryBean<PartitionAttr
}
public void setRecoveryDelay(long recoveryDelay) {
paf.setRecoveryDelay(recoveryDelay);
partitionAttributesFactory.setRecoveryDelay(recoveryDelay);
}
public void setRedundantCopies(int redundantCopies) {
paf.setRedundantCopies(redundantCopies);
partitionAttributesFactory.setRedundantCopies(redundantCopies);
}
public void setStartupRecoveryDelay(long startupRecoveryDelay) {
paf.setStartupRecoveryDelay(startupRecoveryDelay);
partitionAttributesFactory.setStartupRecoveryDelay(startupRecoveryDelay);
}
public void setTotalMaxMemory(long mb) {
paf.setTotalMaxMemory(mb);
partitionAttributesFactory.setTotalMaxMemory(mb);
}
public void setTotalNumBuckets(int numBuckets) {
paf.setTotalNumBuckets(numBuckets);
partitionAttributesFactory.setTotalNumBuckets(numBuckets);
}
@Override
public void afterPropertiesSet() throws Exception {
if (listeners != null) {
for (PartitionListener listener : listeners) {
paf.addPartitionListener(listener);
partitionAttributesFactory.addPartitionListener(listener);
}
}
}
}
}

4
src/main/java/org/springframework/data/gemfire/config/ParsingUtils.java
View File

@@ -111,7 +111,7 @@ abstract class ParsingUtils {
if (StringUtils.hasText(refAttributeValue)) {
if (!childElements.isEmpty()) {
parserContext.getReaderContext().error(String.format(
"Use either the '%1$s' attribute or a nested bean declaration for '%2$s' element, but not both",
"Use either the '%1$s' attribute or a nested bean declaration for '%2$s' element, but not both.",
refAttributeName, element.getLocalName()), element);
}
@@ -163,7 +163,7 @@ abstract class ParsingUtils {
// TODO also triggered when there are no child elements; need to change the message...
if (single) {
parserContext.getReaderContext().error(String.format(
"The element '%1$s' does not support multiple nested bean definitions",
"The element '%1$s' does not support multiple nested bean definitions.",
element.getLocalName()), element);
}
}

14
src/main/java/org/springframework/data/gemfire/config/PartitionedRegionParser.java
View File

@@ -48,24 +48,24 @@ class PartitionedRegionParser extends AbstractRegionParser {
@Override
@SuppressWarnings("unchecked")
protected void doParseRegion(Element element, ParserContext parserContext, BeanDefinitionBuilder builder,
protected void doParseRegion(Element element, ParserContext parserContext, BeanDefinitionBuilder regionBuilder,
boolean subRegion) {
validateDataPolicyShortcutAttributesMutualExclusion(element, parserContext);
super.doParse(element, builder);
super.doParse(element, regionBuilder);
BeanDefinitionBuilder regionAttributesBuilder = BeanDefinitionBuilder.genericBeanDefinition(
RegionAttributesFactoryBean.class);
super.doParseCommonRegionConfiguration(element, parserContext, builder, regionAttributesBuilder, subRegion);
super.doParseCommonRegionConfiguration(element, parserContext, regionBuilder, regionAttributesBuilder, subRegion);
builder.addPropertyValue("attributes", regionAttributesBuilder.getBeanDefinition());
regionBuilder.addPropertyValue("attributes", regionAttributesBuilder.getBeanDefinition());
BeanDefinitionBuilder partitionAttributesBuilder = BeanDefinitionBuilder.genericBeanDefinition(
PartitionAttributesFactoryBean.class);
parseColocatedWith(element, builder, partitionAttributesBuilder, "colocated-with");
parseColocatedWith(element, regionBuilder, partitionAttributesBuilder, "colocated-with");
ParsingUtils.setPropertyValue(element, partitionAttributesBuilder, "copies", "redundantCopies");
ParsingUtils.setPropertyValue(element, partitionAttributesBuilder, "local-max-memory");
ParsingUtils.setPropertyValue(element, partitionAttributesBuilder, "recovery-delay");
@@ -77,14 +77,14 @@ class PartitionedRegionParser extends AbstractRegionParser {
if (partitionResolverSubElement != null) {
partitionAttributesBuilder.addPropertyValue("partitionResolver",
parsePartitionResolver(partitionResolverSubElement, parserContext, builder));
parsePartitionResolver(partitionResolverSubElement, parserContext, regionBuilder));
}
Element partitionListenerSubElement = DomUtils.getChildElementByTagName(element, "partition-listener");
if (partitionListenerSubElement != null) {
partitionAttributesBuilder.addPropertyValue("partitionListeners",
parsePartitionListeners(partitionListenerSubElement, parserContext, builder));
parsePartitionListeners(partitionListenerSubElement, parserContext, regionBuilder));
}
List<Element> fixedPartitionSubElements = DomUtils.getChildElementsByTagName(element, "fixed-partition");

29
src/main/resources/org/springframework/data/gemfire/config/spring-gemfire-1.5.xsd
View File

@@ -1234,21 +1234,38 @@ colocate data based on custom criterias (such as colocating trades by month and
</xsd:appinfo>
</xsd:annotation>
</xsd:element>
<xsd:element name="partition-listener" type="beanDeclarationType"
minOccurs="0" maxOccurs="1">
<xsd:element name="partition-listener" minOccurs="0" maxOccurs="1">
<xsd:annotation>
<xsd:documentation
source="com.gemstone.gemfire.cache.partition.PartitionListener"><![CDATA[
The partition listener definition for this region. Defines a callback for partitioned regions, invoked when a partition region
is created or any bucket in a partitioned region becomes primary
The PartitionListener definition for this Region. Defines a callback for Partitioned Regions, invoked when
a Partition Region is created or any Bucket in a Partitioned Region becomes primary.
]]></xsd:documentation>
<xsd:appinfo>
<tool:annotation>
<tool:exports
type="com.gemstone.gemfire.cache.partition.PartitionListener" />
<tool:exports type="com.gemstone.gemfire.cache.partition.PartitionListener" />
</tool:annotation>
</xsd:appinfo>
</xsd:annotation>
<xsd:complexType>
<xsd:sequence>
<xsd:any namespace="##other" processContents="skip" minOccurs="0" maxOccurs="unbounded">
<xsd:annotation>
<xsd:documentation><![CDATA[
Inner bean definition of the ParitionListener.
]]></xsd:documentation>
</xsd:annotation>
</xsd:any>
</xsd:sequence>
<xsd:attribute name="ref" type="xsd:string" use="optional">
<xsd:annotation>
<xsd:documentation><![CDATA[
The name of the PartitionListener bean referred to by this declaration. Used for convenience. If no reference exists,
use inner bean declarations.
]]></xsd:documentation>
</xsd:annotation>
</xsd:attribute>
</xsd:complexType>
</xsd:element>
<xsd:element name="fixed-partition" minOccurs="0"
maxOccurs="unbounded">

198
src/test/java/org/springframework/data/gemfire/config/PartitionedRegionNamespaceTest.java
View File

@@ -22,12 +22,16 @@ import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertSame;
import static org.junit.Assert.assertTrue;
import java.util.Arrays;
import java.util.List;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.data.gemfire.PartitionedRegionFactoryBean;
import org.springframework.data.gemfire.RegionFactoryBean;
import org.springframework.data.gemfire.SimpleCacheListener;
import org.springframework.data.gemfire.SimplePartitionResolver;
import org.springframework.data.gemfire.TestUtils;
import org.springframework.data.gemfire.test.GemfireTestApplicationContextInitializer;
@@ -36,109 +40,181 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.util.ObjectUtils;
import com.gemstone.gemfire.cache.CacheListener;
import com.gemstone.gemfire.cache.DataPolicy;
import com.gemstone.gemfire.cache.FixedPartitionAttributes;
import com.gemstone.gemfire.cache.PartitionAttributes;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionAttributes;
import com.gemstone.gemfire.cache.partition.PartitionListener;
import com.gemstone.gemfire.cache.partition.PartitionListenerAdapter;
/**
* The PartitionRegionNamespaceTest class is a test suite of test cases testing the contract and functionality
* of the GemFire Partition Region support in SDG.
*
* @author Costin Leau
* @author David Turanski
* @author John Blum
*/
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "partitioned-ns.xml", initializers = GemfireTestApplicationContextInitializer.class)
@SuppressWarnings("unused")
public class PartitionedRegionNamespaceTest {
@Autowired
private ApplicationContext context;
@Test
public void testBasicPartition() throws Exception {
public void testSimplePartitionRegion() throws Exception {
assertTrue(context.containsBean("simple"));
Region<?, ?> simple = context.getBean("simple", Region.class);
assertNotNull(simple);
assertEquals("simple", simple.getName());
assertEquals(Region.SEPARATOR + "simple", simple.getFullPath());
assertNotNull(simple.getAttributes());
assertEquals(DataPolicy.PARTITION, simple.getAttributes().getDataPolicy());
}
@SuppressWarnings("rawtypes")
@Test
public void testPartitionOptions() throws Exception {
@SuppressWarnings("rawtypes")
public void testOptionsPartitionRegion() throws Exception {
assertTrue(context.containsBean("options"));
RegionFactoryBean fb = context.getBean("&options", RegionFactoryBean.class);
assertTrue(fb instanceof PartitionedRegionFactoryBean);
assertEquals(null, TestUtils.readField("scope", fb));
assertEquals("redundant", TestUtils.readField("name", fb));
RegionAttributes attrs = TestUtils.readField("attributes", fb);
assertTrue(attrs.getStatisticsEnabled());
RegionFactoryBean optionsRegionFactoryBean = context.getBean("&options", RegionFactoryBean.class);
PartitionAttributes pAttr = attrs.getPartitionAttributes();
assertTrue(optionsRegionFactoryBean instanceof PartitionedRegionFactoryBean);
assertEquals(null, TestUtils.readField("scope", optionsRegionFactoryBean));
assertEquals("redundant", TestUtils.readField("name", optionsRegionFactoryBean));
assertEquals(1, pAttr.getRedundantCopies());
assertEquals(4, pAttr.getTotalNumBuckets());
assertSame(SimplePartitionResolver.class, pAttr.getPartitionResolver().getClass());
RegionAttributes optionsRegionAttributes = TestUtils.readField("attributes", optionsRegionFactoryBean);
assertNotNull(optionsRegionAttributes);
assertTrue(optionsRegionAttributes.getStatisticsEnabled());
PartitionAttributes optionsRegionPartitionAttributes = optionsRegionAttributes.getPartitionAttributes();
assertNotNull(optionsRegionPartitionAttributes);
assertEquals(1, optionsRegionPartitionAttributes.getRedundantCopies());
assertEquals(4, optionsRegionPartitionAttributes.getTotalNumBuckets());
assertTrue(optionsRegionPartitionAttributes.getPartitionResolver() instanceof SimplePartitionResolver);
}
@SuppressWarnings("rawtypes")
@Test
public void testComplexPartition() throws Exception {
@SuppressWarnings("rawtypes")
public void testComplexPartitionRegion() throws Exception {
assertTrue(context.containsBean("complex"));
RegionFactoryBean fb = context.getBean("&complex", RegionFactoryBean.class);
CacheListener[] listeners = TestUtils.readField("cacheListeners", fb);
assertFalse(ObjectUtils.isEmpty(listeners));
assertEquals(2, listeners.length);
assertSame(listeners[0], context.getBean("c-listener"));
assertSame(context.getBean("c-loader"), TestUtils.readField("cacheLoader", fb));
assertSame(context.getBean("c-writer"), TestUtils.readField("cacheWriter", fb));
RegionFactoryBean complexRegionFactoryBean = context.getBean("&complex", RegionFactoryBean.class);
RegionAttributes attrs = TestUtils.readField("attributes", fb);
PartitionAttributes pAttr = attrs.getPartitionAttributes();
assertEquals(20, pAttr.getLocalMaxMemory());
CacheListener[] cacheListeners = TestUtils.readField("cacheListeners", complexRegionFactoryBean);
assertNotNull(pAttr.getPartitionListeners());
assertEquals(1, pAttr.getPartitionListeners().length);
assertTrue(pAttr.getPartitionListeners()[0] instanceof TestPartitionListener);
assertFalse(ObjectUtils.isEmpty(cacheListeners));
assertEquals(2, cacheListeners.length);
assertSame(cacheListeners[0], context.getBean("c-listener"));
assertTrue(cacheListeners[1] instanceof SimpleCacheListener);
assertSame(context.getBean("c-loader"), TestUtils.readField("cacheLoader", complexRegionFactoryBean));
assertSame(context.getBean("c-writer"), TestUtils.readField("cacheWriter", complexRegionFactoryBean));
RegionAttributes complexRegionAttributes = TestUtils.readField("attributes", complexRegionFactoryBean);
assertNotNull(complexRegionAttributes);
PartitionAttributes complexRegionPartitionAttributes = complexRegionAttributes.getPartitionAttributes();
assertNotNull(complexRegionPartitionAttributes);
assertEquals(20, complexRegionPartitionAttributes.getLocalMaxMemory());
assertNotNull(complexRegionPartitionAttributes.getPartitionListeners());
assertEquals(1, complexRegionPartitionAttributes.getPartitionListeners().length);
assertTrue(complexRegionPartitionAttributes.getPartitionListeners()[0] instanceof TestPartitionListener);
}
@SuppressWarnings("rawtypes")
@Test
@SuppressWarnings("rawtypes")
public void testFixedPartition() throws Exception {
RegionFactoryBean fb = context.getBean("&fixed", RegionFactoryBean.class);
RegionAttributes attrs = TestUtils.readField("attributes", fb);
PartitionAttributes pAttr = attrs.getPartitionAttributes();
assertNotNull(pAttr.getFixedPartitionAttributes());
assertEquals(3, pAttr.getFixedPartitionAttributes().size());
RegionFactoryBean fixedRegionFactoryBean = context.getBean("&fixed", RegionFactoryBean.class);
FixedPartitionAttributes fpa = (FixedPartitionAttributes) pAttr.getFixedPartitionAttributes().get(0);
assertEquals(3, fpa.getNumBuckets());
assertTrue(fpa.isPrimary());
assertNotNull(fixedRegionFactoryBean);
RegionAttributes fixedRegionAttributes = TestUtils.readField("attributes", fixedRegionFactoryBean);
assertNotNull(fixedRegionAttributes);
PartitionAttributes fixedRegionPartitionAttributes = fixedRegionAttributes.getPartitionAttributes();
assertNotNull(fixedRegionPartitionAttributes);
assertNotNull(fixedRegionPartitionAttributes.getFixedPartitionAttributes());
assertEquals(3, fixedRegionPartitionAttributes.getFixedPartitionAttributes().size());
FixedPartitionAttributes fixedPartitionAttributes =
(FixedPartitionAttributes) fixedRegionPartitionAttributes.getFixedPartitionAttributes().get(0);
assertEquals(3, fixedPartitionAttributes.getNumBuckets());
assertTrue(fixedPartitionAttributes.isPrimary());
}
public static class TestPartitionListener implements PartitionListener {
@Test
public void testMultiplePartitionListeners() {
assertTrue(context.containsBean("listeners"));
@Override
public void afterBucketCreated(int arg0, Iterable<?> arg1) {
// TODO Auto-generated method stub
Region<?, ?> listeners = context.getBean("listeners", Region.class);
assertNotNull("The 'listeners' PARTITION Region was not properly configured and initialized!", listeners);
assertEquals("listeners", listeners.getName());
assertEquals(Region.SEPARATOR + "listeners", listeners.getFullPath());
assertNotNull(listeners.getAttributes());
assertEquals(DataPolicy.PARTITION, listeners.getAttributes().getDataPolicy());
PartitionAttributes listenersPartitionAttributes = listeners.getAttributes().getPartitionAttributes();
assertNotNull(listenersPartitionAttributes);
assertNotNull(listenersPartitionAttributes.getPartitionListeners());
assertEquals(4, listenersPartitionAttributes.getPartitionListeners().length);
List<String> expectedNames = Arrays.asList("X", "Y", "Z", "ABC");
for (PartitionListener listener : listenersPartitionAttributes.getPartitionListeners()) {
assertTrue(listener instanceof TestPartitionListener);
assertTrue(expectedNames.contains(listener.toString()));
}
@Override
public void afterBucketRemoved(int arg0, Iterable<?> arg1) {
// TODO Auto-generated method stub
}
@Override
public void afterPrimary(int arg0) {
// TODO Auto-generated method stub
}
@Override
public void afterRegionCreate(Region<?, ?> arg0) {
// TODO Auto-generated method stub
}
}
}
@Test
public void testSinglePartitionListeners() {
assertTrue(context.containsBean("listenerRef"));
Region<?, ?> listeners = context.getBean("listenerRef", Region.class);
assertNotNull("The 'listenerRef' PARTITION Region was not properly configured and initialized!", listeners);
assertEquals("listenerRef", listeners.getName());
assertEquals(Region.SEPARATOR + "listenerRef", listeners.getFullPath());
assertNotNull(listeners.getAttributes());
assertEquals(DataPolicy.PARTITION, listeners.getAttributes().getDataPolicy());
PartitionAttributes listenersPartitionAttributes = listeners.getAttributes().getPartitionAttributes();
assertNotNull(listenersPartitionAttributes);
assertNotNull(listenersPartitionAttributes.getPartitionListeners());
assertEquals(1, listenersPartitionAttributes.getPartitionListeners().length);
assertTrue(listenersPartitionAttributes.getPartitionListeners()[0] instanceof TestPartitionListener);
assertEquals("ABC", listenersPartitionAttributes.getPartitionListeners()[0].toString());
}
public static class TestPartitionListener extends PartitionListenerAdapter {
private String name;
public void setName(final String name) {
this.name = name;
}
@Override
public String toString() {
return this.name;
}
}
}

55
src/test/resources/org/springframework/data/gemfire/config/partitioned-ns.xml
View File

@@ -1,25 +1,30 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:gfe="http://www.springframework.org/schema/gemfire"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/gemfire http://www.springframework.org/schema/gemfire/spring-gemfire.xsd
xmlns:context="http://www.springframework.org/schema/context"
xmlns:gfe="http://www.springframework.org/schema/gemfire"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/gemfire http://www.springframework.org/schema/gemfire/spring-gemfire.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd">
">
<gfe:cache />
<util:properties id="props">
<prop key="copies">1</prop>
<prop key="totalBuckets">4</prop>
</util:properties>
<context:property-placeholder properties-ref="props"/>
<util:properties id="props">
<prop key="totalBuckets">4</prop>
<prop key="copies">1</prop>
</util:properties>
<gfe:partitioned-region id="simple" />
<gfe:partitioned-region id="options" copies="${copies}" total-buckets="${totalBuckets}" name="redundant" close="true" destroy="false" statistics="true">
<gfe:cache/>
<gfe:partitioned-region id="simple"/>
<gfe:partitioned-region id="options" name="redundant" copies="${copies}" statistics="true" total-buckets="${totalBuckets}"
close="true" destroy="false">
<gfe:partition-resolver>
<bean class="org.springframework.data.gemfire.SimplePartitionResolver"/>
</gfe:partition-resolver>
@@ -32,9 +37,9 @@
</gfe:cache-listener>
<gfe:cache-loader ref="c-loader"/>
<gfe:cache-writer ref="c-writer"/>
<gfe:partition-listener>
<bean class="org.springframework.data.gemfire.config.PartitionedRegionNamespaceTest.TestPartitionListener"/>
</gfe:partition-listener>
<gfe:partition-listener>
<bean class="org.springframework.data.gemfire.config.PartitionedRegionNamespaceTest.TestPartitionListener"/>
</gfe:partition-listener>
</gfe:partitioned-region>
<gfe:partitioned-region id="fixed">
@@ -43,8 +48,22 @@
<gfe:fixed-partition partition-name="p3" primary="true"/>
</gfe:partitioned-region>
<gfe:partitioned-region id="listeners" persistent="false">
<gfe:partition-listener>
<bean class="org.springframework.data.gemfire.config.PartitionedRegionNamespaceTest$TestPartitionListener" p:name="X"/>
<bean class="org.springframework.data.gemfire.config.PartitionedRegionNamespaceTest$TestPartitionListener" p:name="Y"/>
<bean class="org.springframework.data.gemfire.config.PartitionedRegionNamespaceTest$TestPartitionListener" p:name="Z"/>
<ref bean="p-listener"/>
</gfe:partition-listener>
</gfe:partitioned-region>
<gfe:partitioned-region id="listenerRef" persistent="false">
<gfe:partition-listener ref="p-listener"/>
</gfe:partitioned-region>
<bean id="c-listener" class="org.springframework.data.gemfire.SimpleCacheListener"/>
<bean id="p-listener" class="org.springframework.data.gemfire.config.PartitionedRegionNamespaceTest$TestPartitionListener" p:name="ABC"/>
<bean id="c-loader" class="org.springframework.data.gemfire.SimpleCacheLoader"/>
<bean id="c-writer" class="org.springframework.data.gemfire.SimpleCacheWriter"/>
</beans>
</beans>