org.infinispan.config
Class Configuration.StateRetrievalType

java.lang.Object
  org.infinispan.config.AbstractConfigurationBean
      org.infinispan.config.AbstractNamedCacheConfigurationBean
          org.infinispan.config.Configuration.StateRetrievalType

All Implemented Interfaces:

Serializable, Cloneable, CloneableConfigurationComponent, FluentConfiguration.ClusteringConfig, FluentConfiguration.StateRetrievalConfig, JAXBUnmarshallable

Enclosing class:

Configuration

public static class Configuration.StateRetrievalType
extends AbstractNamedCacheConfigurationBean
implements FluentConfiguration.StateRetrievalConfig

Configures how state is retrieved when a new cache joins the cluster. This element is only used with invalidation and replication clustered modes.

See Also:

Configuration reference, Serialized Form

Field Summary

protected Boolean	alwaysProvideInMemoryState
protected Boolean	fetchInMemoryState
protected Long	initialRetryWaitTime
protected Long	logFlushTimeout
protected Integer	maxNonProgressingLogWrites
protected Integer	numRetries
protected Integer	retryWaitTimeIncreaseFactor
protected Long	timeout

Fields inherited from class org.infinispan.config.AbstractNamedCacheConfigurationBean

cr

Fields inherited from class org.infinispan.config.AbstractConfigurationBean

overriddenConfigurationElements

Constructor Summary

Configuration.StateRetrievalType()

Method Summary

void	accept(ConfigurationBeanVisitor v)
FluentConfiguration.StateRetrievalConfig	alwaysProvideInMemoryState(Boolean alwaysProvideInMemoryState) If true, this will allow the cache to provide in-memory state to a neighbor, even if the cache is not configured to fetch state from its neighbors (fetchInMemoryState is false)
FluentConfiguration.AsyncConfig	async()
Configuration	build()
Configuration	build()
FluentConfiguration.TransactionConfig	cacheStopTimeout(Integer cacheStopTimeout)
FluentConfiguration.ClusteringConfig	clustering()
FluentConfiguration.ClusteringConfig	clustering()
FluentConfiguration.CustomInterceptorsConfig	customInterceptors()
FluentConfiguration.CustomInterceptorsConfig	customInterceptors()
FluentConfiguration.DataContainerConfig	dataContainer()
FluentConfiguration.DataContainerConfig	dataContainer()
FluentConfiguration.DeadlockDetectionConfig	deadlockDetection() This method allows configuration of the deadlock detection.
FluentConfiguration.DeadlockDetectionConfig	deadlockDetection() This method allows configuration of the deadlock detection.
FluentConfiguration.TransactionConfig	eagerLockSingleNode(Boolean eagerLockSingleNode)
boolean	equals(Object o)
FluentConfiguration.EvictionConfig	eviction()
FluentConfiguration.EvictionConfig	eviction()
FluentConfiguration.ExpirationConfig	expiration()
FluentConfiguration.ExpirationConfig	expiration()
FluentConfiguration.StateRetrievalConfig	fetchInMemoryState(Boolean fetchInMemoryState) If true, this will cause the cache to ask neighboring caches for state when it starts up, so the cache starts 'warm', although it will impact startup time.
Long	getInitialRetryWaitTime()
Long	getLogFlushTimeout()
Integer	getMaxNonProgressingLogWrites()
Integer	getNumRetries()
Integer	getRetryWaitTimeIncreaseFactor()
Long	getTimeout()
FluentConfiguration.HashConfig	hash()
int	hashCode()
FluentConfiguration.IndexingConfig	indexing() This method allows configuration of the indexing subsystem.
FluentConfiguration.IndexingConfig	indexing() This method allows configuration of the indexing subsystem.
FluentConfiguration.StateRetrievalConfig	initialRetryWaitTime(Long initialRetryWaitTime) Initial wait time when backing off before retrying state transfer retrieval
FluentConfiguration.InvocationBatchingConfig	invocationBatching() This method allows configuration of invocation batching.
FluentConfiguration.InvocationBatchingConfig	invocationBatching() This method allows configuration of invocation batching.
Boolean	isAlwaysProvideInMemoryState()
Boolean	isFetchInMemoryState()
FluentConfiguration.JmxStatisticsConfig	jmxStatistics() This method allows configuration of jmx statistics.
FluentConfiguration.JmxStatisticsConfig	jmxStatistics() This method allows configuration of jmx statistics.
FluentConfiguration.L1Config	l1()
FluentConfiguration.LoadersConfig	loaders()
FluentConfiguration.LoadersConfig	loaders()
FluentConfiguration.LockingConfig	locking()
FluentConfiguration.LockingConfig	locking()
FluentConfiguration.StateRetrievalConfig	logFlushTimeout(Long logFlushTimeout) This is the maximum amount of time to run a cluster-wide flush, to allow for syncing of transaction logs.
FluentConfiguration.StateRetrievalConfig	maxNonProgressingLogWrites(Integer maxNonProgressingLogWrites) This is the maximum number of non-progressing transaction log writes after which a brute-force flush approach is resorted to, to synchronize transaction logs.
FluentConfiguration.ClusteringConfig	mode(Configuration.CacheMode mode)
FluentConfiguration.StateRetrievalConfig	numRetries(Integer numRetries) Number of state retrieval retries before giving up and aborting startup.
FluentConfiguration.RecoveryConfig	recovery()
FluentConfiguration.StateRetrievalConfig	retryWaitTimeIncreaseFactor(Integer retryWaitTimeIncreaseFactor) Wait time increase factor over successive state retrieval backoffs
void	setAlwaysProvideInMemoryState(Boolean alwaysProvideInMemoryState) Deprecated. The visibility of this will be reduced, use alwaysProvideInMemoryState(Boolean) instead
protected org.infinispan.config.AbstractFluentConfigurationBean	setConfiguration(Configuration config)
void	setFetchInMemoryState(Boolean fetchInMemoryState) Deprecated. The visibility of this will be reduced, use fetchInMemoryState(Boolean) instead
void	setInitialRetryWaitTime(Long initialRetryWaitTime) Deprecated. The visibility of this will be reduced, use initialRetryWaitTime(Long) instead
void	setLogFlushTimeout(Long logFlushTimeout) Deprecated. The visibility of this will be reduced, use logFlushTimeout(Long) instead
void	setMaxNonProgressingLogWrites(Integer maxNonProgressingLogWrites) Deprecated. The visibility of this will be reduced, use maxNonProgressingLogWrites(Integer) instead
void	setNumRetries(Integer numRetries) Deprecated. The visibility of this will be reduced, use numRetries(Integer) instead
void	setRetryWaitTimeIncreaseFactor(Integer retryWaitTimeIncreaseFactor) Deprecated. The visibility of this will be reduced, use retryWaitTimeIncreaseFactor(Integer) instead
void	setTimeout(Long timeout) Deprecated. The visibility of this will be reduced, use timeout(Long) instead
FluentConfiguration.StateRetrievalConfig	stateRetrieval()
FluentConfiguration.StoreAsBinaryConfig	storeAsBinary() This method allows configuration of lazy deserialization.
FluentConfiguration.StoreAsBinaryConfig	storeAsBinary() This method allows configuration of lazy deserialization.
FluentConfiguration.SyncConfig	sync()
FluentConfiguration.TransactionConfig	syncCommitPhase(Boolean syncCommitPhase)
FluentConfiguration.TransactionConfig	syncRollbackPhase(Boolean syncRollbackPhase)
FluentConfiguration.StateRetrievalConfig	timeout(Long timeout) This is the maximum amount of time - in milliseconds - to wait for state from neighboring caches, before throwing an exception and aborting startup.
FluentConfiguration.TransactionConfig	transaction()
FluentConfiguration.TransactionConfig	transaction()
FluentConfiguration.TransactionConfig	transactionManagerLookup(TransactionManagerLookup transactionManagerLookup)
FluentConfiguration.TransactionConfig	transactionManagerLookupClass(Class<? extends TransactionManagerLookup> transactionManagerLookupClass)
FluentConfiguration.TransactionConfig	transactionSynchronizationRegistryLookup(TransactionSynchronizationRegistryLookup transactionSynchronizationRegistryLookup)
FluentConfiguration.UnsafeConfig	unsafe()
FluentConfiguration.UnsafeConfig	unsafe()
FluentConfiguration.TransactionConfig	useEagerLocking(Boolean useEagerLocking)
FluentConfiguration.TransactionConfig	useSynchronization(Boolean useSynchronization)

Methods inherited from class org.infinispan.config.AbstractNamedCacheConfigurationBean

clone, hasComponentStarted, inject

Methods inherited from class org.infinispan.config.AbstractConfigurationBean

testImmutability, toTypedProperties, toTypedProperties, uc, willUnmarshall

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.config.FluentConfiguration.ClusteringConfig

async, hash, l1, mode, stateRetrieval, sync

Field Detail

fetchInMemoryState

@Dynamic
protected Boolean fetchInMemoryState

alwaysProvideInMemoryState

protected Boolean alwaysProvideInMemoryState

timeout

@Dynamic
protected Long timeout

initialRetryWaitTime

protected Long initialRetryWaitTime

retryWaitTimeIncreaseFactor

protected Integer retryWaitTimeIncreaseFactor

numRetries

protected Integer numRetries

logFlushTimeout

protected Long logFlushTimeout

maxNonProgressingLogWrites

protected Integer maxNonProgressingLogWrites

Constructor Detail

Configuration.StateRetrievalType

public Configuration.StateRetrievalType()

Method Detail

accept

public void accept(ConfigurationBeanVisitor v)

isFetchInMemoryState

public Boolean isFetchInMemoryState()

setFetchInMemoryState

@Deprecated
public void setFetchInMemoryState(Boolean fetchInMemoryState)

Deprecated. The visibility of this will be reduced, use fetchInMemoryState(Boolean) instead

fetchInMemoryState

public FluentConfiguration.StateRetrievalConfig fetchInMemoryState(Boolean fetchInMemoryState)

Description copied from interface: FluentConfiguration.StateRetrievalConfig

If true, this will cause the cache to ask neighboring caches for state when it starts up, so the cache starts 'warm', although it will impact startup time.

Specified by:

fetchInMemoryState in interface FluentConfiguration.StateRetrievalConfig

isAlwaysProvideInMemoryState

public Boolean isAlwaysProvideInMemoryState()

setAlwaysProvideInMemoryState

@Deprecated
public void setAlwaysProvideInMemoryState(Boolean alwaysProvideInMemoryState)

Deprecated. The visibility of this will be reduced, use alwaysProvideInMemoryState(Boolean) instead

alwaysProvideInMemoryState

public FluentConfiguration.StateRetrievalConfig alwaysProvideInMemoryState(Boolean alwaysProvideInMemoryState)

Description copied from interface: FluentConfiguration.StateRetrievalConfig

If true, this will allow the cache to provide in-memory state to a neighbor, even if the cache is not configured to fetch state from its neighbors (fetchInMemoryState is false)

Specified by:

alwaysProvideInMemoryState in interface FluentConfiguration.StateRetrievalConfig

getInitialRetryWaitTime

public Long getInitialRetryWaitTime()

setInitialRetryWaitTime

@Deprecated
public void setInitialRetryWaitTime(Long initialRetryWaitTime)

Deprecated. The visibility of this will be reduced, use initialRetryWaitTime(Long) instead

initialRetryWaitTime

public FluentConfiguration.StateRetrievalConfig initialRetryWaitTime(Long initialRetryWaitTime)

Description copied from interface: FluentConfiguration.StateRetrievalConfig

Initial wait time when backing off before retrying state transfer retrieval

Specified by:

initialRetryWaitTime in interface FluentConfiguration.StateRetrievalConfig

getRetryWaitTimeIncreaseFactor

public Integer getRetryWaitTimeIncreaseFactor()

setRetryWaitTimeIncreaseFactor

@Deprecated
public void setRetryWaitTimeIncreaseFactor(Integer retryWaitTimeIncreaseFactor)

Deprecated. The visibility of this will be reduced, use retryWaitTimeIncreaseFactor(Integer) instead

retryWaitTimeIncreaseFactor

public FluentConfiguration.StateRetrievalConfig retryWaitTimeIncreaseFactor(Integer retryWaitTimeIncreaseFactor)

Description copied from interface: FluentConfiguration.StateRetrievalConfig

Wait time increase factor over successive state retrieval backoffs

Specified by:

retryWaitTimeIncreaseFactor in interface FluentConfiguration.StateRetrievalConfig

getNumRetries

public Integer getNumRetries()

setNumRetries

@Deprecated
public void setNumRetries(Integer numRetries)

Deprecated. The visibility of this will be reduced, use numRetries(Integer) instead

numRetries

public FluentConfiguration.StateRetrievalConfig numRetries(Integer numRetries)

Description copied from interface: FluentConfiguration.StateRetrievalConfig

Number of state retrieval retries before giving up and aborting startup.

Specified by:

numRetries in interface FluentConfiguration.StateRetrievalConfig

getTimeout

public Long getTimeout()

setTimeout

@Deprecated
public void setTimeout(Long timeout)

Deprecated. The visibility of this will be reduced, use timeout(Long) instead

timeout

public FluentConfiguration.StateRetrievalConfig timeout(Long timeout)

Description copied from interface: FluentConfiguration.StateRetrievalConfig

This is the maximum amount of time - in milliseconds - to wait for state from neighboring caches, before throwing an exception and aborting startup.

Specified by:

timeout in interface FluentConfiguration.StateRetrievalConfig

getLogFlushTimeout

public Long getLogFlushTimeout()

setLogFlushTimeout

@Deprecated
public void setLogFlushTimeout(Long logFlushTimeout)

Deprecated. The visibility of this will be reduced, use logFlushTimeout(Long) instead

logFlushTimeout

public FluentConfiguration.StateRetrievalConfig logFlushTimeout(Long logFlushTimeout)

Description copied from interface: FluentConfiguration.StateRetrievalConfig

This is the maximum amount of time to run a cluster-wide flush, to allow for syncing of transaction logs.

Specified by:

logFlushTimeout in interface FluentConfiguration.StateRetrievalConfig

getMaxNonProgressingLogWrites

public Integer getMaxNonProgressingLogWrites()

setMaxNonProgressingLogWrites

@Deprecated
public void setMaxNonProgressingLogWrites(Integer maxNonProgressingLogWrites)

Deprecated. The visibility of this will be reduced, use maxNonProgressingLogWrites(Integer) instead

maxNonProgressingLogWrites

public FluentConfiguration.StateRetrievalConfig maxNonProgressingLogWrites(Integer maxNonProgressingLogWrites)

Description copied from interface: FluentConfiguration.StateRetrievalConfig

This is the maximum number of non-progressing transaction log writes after which a brute-force flush approach is resorted to, to synchronize transaction logs.

Specified by:

maxNonProgressingLogWrites in interface FluentConfiguration.StateRetrievalConfig

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

locking

public FluentConfiguration.LockingConfig locking()

loaders

public FluentConfiguration.LoadersConfig loaders()

transaction

public FluentConfiguration.TransactionConfig transaction()

deadlockDetection

public FluentConfiguration.DeadlockDetectionConfig deadlockDetection()

This method allows configuration of the deadlock detection. When this method is called, it automatically enables deadlock detection. So, if you want it to be disabled, make sure you call FluentConfiguration.DeadlockDetectionConfig.disable()

customInterceptors

public FluentConfiguration.CustomInterceptorsConfig customInterceptors()

eviction

public FluentConfiguration.EvictionConfig eviction()

expiration

public FluentConfiguration.ExpirationConfig expiration()

clustering

public FluentConfiguration.ClusteringConfig clustering()

indexing

public FluentConfiguration.IndexingConfig indexing()

This method allows configuration of the indexing subsystem. When this method is called, it automatically enables indexing. So, if you want it to be disabled, make sure you call FluentConfiguration.IndexingConfig.disable()

dataContainer

public FluentConfiguration.DataContainerConfig dataContainer()

unsafe

public FluentConfiguration.UnsafeConfig unsafe()

jmxStatistics

public FluentConfiguration.JmxStatisticsConfig jmxStatistics()

This method allows configuration of jmx statistics. When this method is called, it automatically enables jmx statistics.

storeAsBinary

public FluentConfiguration.StoreAsBinaryConfig storeAsBinary()

This method allows configuration of lazy deserialization. When this method is called, it automatically enables lazy deserialization.

invocationBatching

public FluentConfiguration.InvocationBatchingConfig invocationBatching()

This method allows configuration of invocation batching. When this method is called, it automatically enables invocation batching.

build

public Configuration build()

locking

public FluentConfiguration.LockingConfig locking()

loaders

public FluentConfiguration.LoadersConfig loaders()

transaction

public FluentConfiguration.TransactionConfig transaction()

deadlockDetection

public FluentConfiguration.DeadlockDetectionConfig deadlockDetection()

This method allows configuration of the deadlock detection. When this method is called, it automatically enables deadlock detection. So, if you want it to be disabled, make sure you call FluentConfiguration.DeadlockDetectionConfig.disable()

customInterceptors

public FluentConfiguration.CustomInterceptorsConfig customInterceptors()

eviction

public FluentConfiguration.EvictionConfig eviction()

expiration

public FluentConfiguration.ExpirationConfig expiration()

clustering

public FluentConfiguration.ClusteringConfig clustering()

indexing

public FluentConfiguration.IndexingConfig indexing()

This method allows configuration of the indexing subsystem. When this method is called, it automatically enables indexing. So, if you want it to be disabled, make sure you call FluentConfiguration.IndexingConfig.disable()

dataContainer

public FluentConfiguration.DataContainerConfig dataContainer()

unsafe

public FluentConfiguration.UnsafeConfig unsafe()

jmxStatistics

public FluentConfiguration.JmxStatisticsConfig jmxStatistics()

This method allows configuration of jmx statistics. When this method is called, it automatically enables jmx statistics.

storeAsBinary

public FluentConfiguration.StoreAsBinaryConfig storeAsBinary()

This method allows configuration of lazy deserialization. When this method is called, it automatically enables lazy deserialization.

invocationBatching

public FluentConfiguration.InvocationBatchingConfig invocationBatching()

This method allows configuration of invocation batching. When this method is called, it automatically enables invocation batching.

async

public FluentConfiguration.AsyncConfig async()

sync

public FluentConfiguration.SyncConfig sync()

stateRetrieval

public FluentConfiguration.StateRetrievalConfig stateRetrieval()

l1

public FluentConfiguration.L1Config l1()

hash

public FluentConfiguration.HashConfig hash()

mode

public FluentConfiguration.ClusteringConfig mode(Configuration.CacheMode mode)

transactionManagerLookupClass

public FluentConfiguration.TransactionConfig transactionManagerLookupClass(Class<? extends TransactionManagerLookup> transactionManagerLookupClass)

transactionManagerLookup

public FluentConfiguration.TransactionConfig transactionManagerLookup(TransactionManagerLookup transactionManagerLookup)

transactionSynchronizationRegistryLookup

public FluentConfiguration.TransactionConfig transactionSynchronizationRegistryLookup(TransactionSynchronizationRegistryLookup transactionSynchronizationRegistryLookup)

syncCommitPhase

public FluentConfiguration.TransactionConfig syncCommitPhase(Boolean syncCommitPhase)

syncRollbackPhase

public FluentConfiguration.TransactionConfig syncRollbackPhase(Boolean syncRollbackPhase)

useEagerLocking

public FluentConfiguration.TransactionConfig useEagerLocking(Boolean useEagerLocking)

eagerLockSingleNode

public FluentConfiguration.TransactionConfig eagerLockSingleNode(Boolean eagerLockSingleNode)

cacheStopTimeout

public FluentConfiguration.TransactionConfig cacheStopTimeout(Integer cacheStopTimeout)

useSynchronization

public FluentConfiguration.TransactionConfig useSynchronization(Boolean useSynchronization)

recovery

public FluentConfiguration.RecoveryConfig recovery()

build

public Configuration build()

setConfiguration

protected org.infinispan.config.AbstractFluentConfigurationBean setConfiguration(Configuration config)