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

+ minor change in cache version + name message

Browse Source
This commit is contained in:
costin
2010-07-30 13:46:36 +03:00
parent 8dfdfa7bdb
commit 7a143259aa
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/org/springframework/data/gemfire/CacheFactoryBean.java
View File

@@ -80,8 +80,8 @@ public class CacheFactoryBean implements BeanNameAware, BeanFactoryAware, BeanCl
system = DistributedSystem.connect(cfgProps);
DistributedMember member = system.getDistributedMember();
log.info("Connected to Distributed System [" + system.getName() + "=" + member.getId() + "@"
+ member.getHost() + "]");
log.info("Connected to Distributed System [" + system.getName() + "=" + member.getId() + "@" + member.getHost()
+ "]");
// use the bean class loader to load Declarable classes
Thread th = Thread.currentThread();
@@ -139,9 +139,14 @@ public class CacheFactoryBean implements BeanNameAware, BeanFactoryAware, BeanCl
return GemfireCacheUtils.convertGemfireAccessException((GemFireException) ex);
}
if (ex instanceof IllegalArgumentException) {
if (ex instanceof IndexInvalidException || ex instanceof CqInvalidException
|| ex instanceof QueryInvalidException) {
return GemfireCacheUtils.convertGemfireAccessException((IllegalArgumentException) ex);
if (ex instanceof IndexInvalidException) {
return GemfireCacheUtils.convertGemfireAccessException((IndexInvalidException) ex);
}
if (ex instanceof CqInvalidException) {
return GemfireCacheUtils.convertGemfireAccessException((CqInvalidException) ex);
}
if (ex instanceof QueryInvalidException) {
return GemfireCacheUtils.convertGemfireAccessException((QueryInvalidException) ex);
}
}