kodo.datacache
Class GemFireQueryCache

java.lang.Object
  org.apache.openjpa.lib.util.concurrent.AbstractConcurrentEventManager
      org.apache.openjpa.datacache.AbstractQueryCache
          kodo.datacache.GemFireQueryCache

All Implemented Interfaces:

org.apache.openjpa.datacache.QueryCache, org.apache.openjpa.datacache.TypesChangedListener, org.apache.openjpa.lib.conf.Configurable, org.apache.openjpa.lib.util.Closeable, org.apache.openjpa.lib.util.EventManager

public class GemFireQueryCache
extends org.apache.openjpa.datacache.AbstractQueryCache

A query cache that delegates to a GemStone GemFire cache.

To use GemFire in Kodo set kodo.QueryCache to gemfire

By default, a GemFire region of root/kodo-query-cache is used. This can be changed be setting the optional property CacheName

Some notes regarding using Kodo with GemFire: - Externalized fields must externalize to a serializable type - The Kodo option of DynamicDataStructs and custom field proxies aren't currently supported with GemFire

Field Summary

static String

DEFAULT_CACHE_NAME

Fields inherited from class org.apache.openjpa.datacache.AbstractQueryCache

conf, log

Constructor Summary

GemFireQueryCache()

Method Summary

protected void	clearInternal()
void	endConfiguration()
String	getGemFireCacheName() Gets the name of the GemFire cache region to use.
protected org.apache.openjpa.datacache.QueryResult	getInternal(org.apache.openjpa.datacache.QueryKey key)
void	initialize(org.apache.openjpa.datacache.DataCacheManager mgr)
protected Collection	keySet()
protected GemFireCacheWrapper	newCacheWrapper() Create a new GemFire cache wrapper for internal use.
protected boolean	pinInternal(org.apache.openjpa.datacache.QueryKey key) GemFire doesn't have a concept of pinning data.
protected org.apache.openjpa.datacache.QueryResult	putInternal(org.apache.openjpa.datacache.QueryKey key, org.apache.openjpa.datacache.QueryResult value)
protected boolean	recacheUpdates()
protected org.apache.openjpa.datacache.QueryResult	removeInternal(org.apache.openjpa.datacache.QueryKey key)
void	setGemfireCacheName(String name) Deprecated. Retained for auto-conf compatibility with old conf files.
void	setGemFireCacheName(String name) Sets the name of the GemFire cache region to use.
void	startConfiguration()
protected boolean	unpinInternal(org.apache.openjpa.datacache.QueryKey key) GemFire doesn't have a concept of pinning data.
void	writeLock()
void	writeUnlock()

Methods inherited from class org.apache.openjpa.datacache.AbstractQueryCache

addTypesChangedListener, afterCommit, clear, close, close, fireEvent, get, isClosed, newListenerCollection, onTypesChanged, pin, put, remove, removeAllInternal, removeTypesChangedListener, setConfiguration, unpin

Methods inherited from class org.apache.openjpa.lib.util.concurrent.AbstractConcurrentEventManager

addListener, fireEvent, getListeners, hasListener, hasListeners, isFailFast, removeListener, setFailFast

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_CACHE_NAME

public static final String DEFAULT_CACHE_NAME

See Also:

Constant Field Values

Constructor Detail

GemFireQueryCache

public GemFireQueryCache()

Method Detail

setGemFireCacheName

public void setGemFireCacheName(String name)

Sets the name of the GemFire cache region to use.

setGemfireCacheName

public void setGemfireCacheName(String name)

Deprecated. Retained for auto-conf compatibility with old conf files.

getGemFireCacheName

public String getGemFireCacheName()

Gets the name of the GemFire cache region to use.

startConfiguration

public void startConfiguration()

Specified by:

startConfiguration in interface org.apache.openjpa.lib.conf.Configurable

Overrides:

startConfiguration in class org.apache.openjpa.datacache.AbstractQueryCache

endConfiguration

public void endConfiguration()

Specified by:

endConfiguration in interface org.apache.openjpa.lib.conf.Configurable

Overrides:

endConfiguration in class org.apache.openjpa.datacache.AbstractQueryCache

newCacheWrapper

protected GemFireCacheWrapper newCacheWrapper()

Create a new GemFire cache wrapper for internal use.

writeLock

public void writeLock()

writeUnlock

public void writeUnlock()

getInternal

protected org.apache.openjpa.datacache.QueryResult getInternal(org.apache.openjpa.datacache.QueryKey key)

Specified by:

getInternal in class org.apache.openjpa.datacache.AbstractQueryCache

putInternal

protected org.apache.openjpa.datacache.QueryResult putInternal(org.apache.openjpa.datacache.QueryKey key,
                                                               org.apache.openjpa.datacache.QueryResult value)

Specified by:

putInternal in class org.apache.openjpa.datacache.AbstractQueryCache

removeInternal

protected org.apache.openjpa.datacache.QueryResult removeInternal(org.apache.openjpa.datacache.QueryKey key)

Specified by:

removeInternal in class org.apache.openjpa.datacache.AbstractQueryCache

clearInternal

protected void clearInternal()

Specified by:

clearInternal in class org.apache.openjpa.datacache.AbstractQueryCache

pinInternal

protected boolean pinInternal(org.apache.openjpa.datacache.QueryKey key)

GemFire doesn't have a concept of pinning data. This method is equivalent to invoking Map#contains.

Specified by:

pinInternal in class org.apache.openjpa.datacache.AbstractQueryCache

unpinInternal

protected boolean unpinInternal(org.apache.openjpa.datacache.QueryKey key)

GemFire doesn't have a concept of pinning data. This method is equivalent to invoking Map#contains.

Specified by:

unpinInternal in class org.apache.openjpa.datacache.AbstractQueryCache

recacheUpdates

protected boolean recacheUpdates()

keySet

protected Collection keySet()

Specified by:

keySet in class org.apache.openjpa.datacache.AbstractQueryCache

initialize

public void initialize(org.apache.openjpa.datacache.DataCacheManager mgr)

Specified by:

initialize in interface org.apache.openjpa.datacache.QueryCache

Overrides:

initialize in class org.apache.openjpa.datacache.AbstractQueryCache