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

SGF-192 - ClientRegionParser now processes close and destroy attributes

Browse Source
This commit is contained in:
David Turanski
2013-08-05 11:42:39 -04:00
parent 6b523a064e
commit cb45af775f
10 changed files with 114 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/springframework/data/gemfire/client/PoolFactoryBean.java
View File

@@ -188,8 +188,9 @@ public class PoolFactoryBean implements FactoryBean<Pool>, InitializingBean,
if (!pool.isDestroyed()) {
pool.releaseThreadLocalConnection();
pool.destroy(keepAlive);
if (log.isDebugEnabled())
if (log.isDebugEnabled()) {
log.debug("Destroyed pool '" + name + "'...");
}
}
}
}

3
src/main/java/org/springframework/data/gemfire/config/ClientRegionParser.java
View File

@@ -74,7 +74,8 @@ class ClientRegionParser extends AliasReplacingBeanDefinitionParser {
attr = element.getAttribute("cache-ref");
// add cache reference (fallback to default if nothing is specified)
builder.addPropertyReference("cache", (StringUtils.hasText(attr) ? attr : GemfireConstants.DEFAULT_GEMFIRE_CACHE_NAME));
ParsingUtils.setPropertyValue(element, builder, "close");
ParsingUtils.setPropertyValue(element, builder, "destroy");
// eviction + overflow attributes
// client attributes
BeanDefinitionBuilder attrBuilder = BeanDefinitionBuilder

2
src/main/java/org/springframework/data/gemfire/listener/ContinuousQueryListenerContainer.java
View File

@@ -274,7 +274,7 @@ public class ContinuousQueryListenerContainer implements InitializingBean, Dispo
this.errorHandler.handleError(ex);
}
else if (logger.isWarnEnabled()) {
logger.warn("Execution of JMS event listener failed, and no ErrorHandler has been set.", ex);
logger.warn("Execution of the CQ event listener failed, and no ErrorHandler has been set.", ex);
}
}