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

SGF-539 - Change GemfireCache.evict(key) to call Region.remove(key).

Browse Source
This commit is contained in:
John Blum
2016-10-03 23:59:54 -07:00
parent d914f74274
commit a4abc83adb
7 changed files with 367 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/springframework/data/gemfire/support/GemfireCache.java
View File

@@ -101,7 +101,7 @@ public class GemfireCache implements Cache {
* @see com.gemstone.gemfire.cache.Region#destroy(Object)
*/
public void evict(Object key) {
getNativeCache().destroy(key);
getNativeCache().remove(key);
}
/**

16
src/main/java/org/springframework/data/gemfire/support/GemfireCacheManager.java
View File

@@ -103,7 +103,7 @@ public class GemfireCacheManager extends AbstractCacheManager {
Collection<Cache> caches = new HashSet<Cache>(regions.size());
for (Region<?, ?> region : regions) {
caches.add(GemfireCache.wrap(region));
caches.add(newGemfireCache(region));
}
return caches;
@@ -136,6 +136,18 @@ public class GemfireCacheManager extends AbstractCacheManager {
return (collection != null && collection.iterator().hasNext());
}
/**
* Constructs a new instance of {@link GemfireCache} initialized with the given GemFire {@link Region}.
*
* @param region GemFire {@link Region} to wrap (adapt).
* @return an instance of {@link GemfireCache} initialized with the given GemFire {@link Region}.
* @see org.springframework.data.gemfire.support.GemfireCache
* @see com.gemstone.gemfire.cache.Region
*/
protected GemfireCache newGemfireCache(Region<?, ?> region) {
return GemfireCache.wrap(region);
}
/* (non-Javadoc) */
Region<?, ?> regionFor(GemFireCache gemfireCache, String cacheName) {
return assertGemFireRegionAvailable(assertGemFireCacheAvailable(gemfireCache).getRegion(cacheName), cacheName);
@@ -159,7 +171,7 @@ public class GemfireCacheManager extends AbstractCacheManager {
protected Cache getMissingCache(String name) {
Cache cache = super.getMissingCache(name);
return (cache != null ? cache : (isDynamic() ? GemfireCache.wrap(regionFor(this.gemfireCache, name)) : null));
return (cache != null ? cache : (isDynamic() ? newGemfireCache(regionFor(this.gemfireCache, name)) : null));
}
/**