org.infinispan.loaders.decorators

Class AsyncStoreConfig

java.lang.Object

org.infinispan.config.AbstractConfigurationBean

org.infinispan.config.AbstractNamedCacheConfigurationBean

org.infinispan.loaders.decorators.AbstractDecoratorConfigurationBean

org.infinispan.loaders.decorators.AsyncStoreConfig

All Implemented Interfaces:

Serializable, Cloneable, CloneableConfigurationComponent, JAXBUnmarshallable, CacheLoaderConfig, CacheStoreConfig

public class AsyncStoreConfig
extends AbstractDecoratorConfigurationBean

Configuration for the async cache loader. If enabled, this provides you with asynchronous writes to the cache store, giving you 'write-behind' caching.

Since:

4.0

Author:

Manik Surtani, Vladimir Blagojevic

See Also:

Configuration reference, Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Boolean	enabled
protected Long	flushLockTimeout
protected Integer	modificationQueueSize
protected Long	shutdownTimeout
protected Integer	threadPoolSize

Fields inherited from class org.infinispan.config.AbstractNamedCacheConfigurationBean

cr

Fields inherited from class org.infinispan.config.AbstractConfigurationBean

overriddenConfigurationElements

Constructor Summary

Constructors

Constructor and Description
AsyncStoreConfig()

Method Summary

Methods

Modifier and Type	Method and Description
void	accept(ConfigurationBeanVisitor v)
AsyncStoreConfig	clone()
AsyncStoreConfig	flushLockTimeout(Long stateLockTimeout) Timeout to acquire the lock which guards the state to be flushed to the cache store periodically.
Long	getFlushLockTimeout()
Integer	getModificationQueueSize()
Long	getShutdownTimeout()
Integer	getThreadPoolSize()
Boolean	isEnabled()
AsyncStoreConfig	modificationQueueSize(Integer modificationQueueSize)
void	setEnabled(Boolean enabled) Deprecated. The visibility of this method will be reduced in favour of more fluent writer method calls.
AsyncStoreConfig	setFlushLockTimeout(Long stateLockTimeout) Deprecated. The visibility of this method will be reduced. Use flushLockTimeout(Long) instead.
void	setModificationQueueSize(Integer modificationQueueSize) Deprecated.
void	setShutdownTimeout(Long shutdownTimeout) Deprecated. The visibility of this method will be reduced. Use shutdownTimeout(Long) instead.
void	setThreadPoolSize(Integer threadPoolSize) Deprecated. The visibility of this method will be reduced. Use threadPoolSize(Integer) instead.
AsyncStoreConfig	shutdownTimeout(Long shutdownTimeout) Timeout to stop the cache store.
AsyncStoreConfig	threadPoolSize(Integer threadPoolSize) Size of the thread pool whose threads are responsible for applying the modifications.

Methods inherited from class org.infinispan.loaders.decorators.AbstractDecoratorConfigurationBean

asyncStore, build, fetchPersistentState, getAsyncStoreConfig, getCacheLoaderClassName, getClassLoader, getPurgerThreads, getSingletonStoreConfig, ignoreModifications, isFetchPersistentState, isIgnoreModifications, isPurgeOnStartup, isPurgeSynchronously, purgeOnStartup, purgerThreads, purgeSynchronously, setAsyncStoreConfig, setCacheLoaderClassName, setCacheStoreConfig, setFetchPersistentState, setIgnoreModifications, setPurgeOnStartup, setPurgeSynchronously, setSingletonStoreConfig, singletonStore

Methods inherited from class org.infinispan.config.AbstractNamedCacheConfigurationBean

hasComponentStarted, inject

Methods inherited from class org.infinispan.config.AbstractConfigurationBean

testImmutability, toTypedProperties, toTypedProperties, uc, willUnmarshall

Methods inherited from class java.lang.Object

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

Field Detail

enabled

protected Boolean enabled

threadPoolSize

protected Integer threadPoolSize

flushLockTimeout

@Dynamic
protected Long flushLockTimeout

shutdownTimeout

@Dynamic
protected Long shutdownTimeout

modificationQueueSize

protected Integer modificationQueueSize

Constructor Detail

AsyncStoreConfig

public AsyncStoreConfig()

Method Detail

isEnabled

public Boolean isEnabled()

setEnabled

@Deprecated
public void setEnabled(Boolean enabled)

Deprecated. The visibility of this method will be reduced in favour of more fluent writer method calls.

If true, all modifications to this cache store happen asynchronously, on a separate thread.

Parameters:

enabled -

getThreadPoolSize

public Integer getThreadPoolSize()

setThreadPoolSize

@Deprecated
public void setThreadPoolSize(Integer threadPoolSize)

Deprecated. The visibility of this method will be reduced. Use threadPoolSize(Integer) instead.

Size of the thread pool whose threads are responsible for applying the modifications.

Parameters:

threadPoolSize -

threadPoolSize

public AsyncStoreConfig threadPoolSize(Integer threadPoolSize)

Size of the thread pool whose threads are responsible for applying the modifications.

Parameters:

threadPoolSize -

getFlushLockTimeout

public Long getFlushLockTimeout()

setFlushLockTimeout

@Deprecated
public AsyncStoreConfig setFlushLockTimeout(Long stateLockTimeout)

Deprecated. The visibility of this method will be reduced. Use flushLockTimeout(Long) instead.

Timeout to acquire the lock which guards the state to be flushed to the cache store periodically.

Parameters:

stateLockTimeout -

flushLockTimeout

public AsyncStoreConfig flushLockTimeout(Long stateLockTimeout)

Timeout to acquire the lock which guards the state to be flushed to the cache store periodically.

Parameters:

stateLockTimeout -

getShutdownTimeout

public Long getShutdownTimeout()

setShutdownTimeout

@Deprecated
public void setShutdownTimeout(Long shutdownTimeout)

Deprecated. The visibility of this method will be reduced. Use shutdownTimeout(Long) instead.

Timeout to stop the cache store. When the store is stopped it's possible that some modifications still need to be applied; you likely want to set a very large timeout to make sure to not loose data

Parameters:

shutdownTimeout -

shutdownTimeout

public AsyncStoreConfig shutdownTimeout(Long shutdownTimeout)

Timeout to stop the cache store. When the store is stopped it's possible that some modifications still need to be applied; you likely want to set a very large timeout to make sure to not loose data

Parameters:

shutdownTimeout -

getModificationQueueSize

public Integer getModificationQueueSize()

modificationQueueSize

public AsyncStoreConfig modificationQueueSize(Integer modificationQueueSize)

setModificationQueueSize

@Deprecated
public void setModificationQueueSize(Integer modificationQueueSize)

Deprecated.

Sets the size of the modification queue for the async store. If updates are made at a rate that is faster than the underlying cache store can process this queue, then the async store behaves like a synchronous store for that period, blocking until the queue can accept more elements.

Parameters:

modificationQueueSize - The size of the modification queue

clone

public AsyncStoreConfig clone()

Specified by:

clone in interface CloneableConfigurationComponent

Specified by:

clone in interface CacheLoaderConfig

Overrides:

clone in class AbstractDecoratorConfigurationBean

accept

public void accept(ConfigurationBeanVisitor v)