public class AsyncConfigurationBuilder extends AbstractClusteringConfigurationChildBuilder
Modifier and Type | Field and Description |
---|---|
private boolean |
asyncMarshalling |
private org.infinispan.remoting.ReplicationQueue |
replicationQueue |
private long |
replicationQueueInterval |
private int |
replicationQueueMaxElements |
private boolean |
useReplicationQueue |
Modifier | Constructor and Description |
---|---|
protected |
AsyncConfigurationBuilder(ClusteringConfigurationBuilder builder) |
Modifier and Type | Method and Description |
---|---|
AsyncConfigurationBuilder |
asyncMarshalling()
Enable asynchronous marshalling.
|
AsyncConfigurationBuilder |
asyncMarshalling(boolean async) |
AsyncConfiguration |
create() |
AsyncConfigurationBuilder |
read(AsyncConfiguration template) |
AsyncConfigurationBuilder |
replQueue(org.infinispan.remoting.ReplicationQueue replicationQueue)
The replication queue in use, by default
ReplicationQueueImpl . |
AsyncConfigurationBuilder |
replQueueInterval(long interval)
If useReplQueue is set to true, this attribute controls how often the asynchronous thread used
to flush the replication queue runs.
|
AsyncConfigurationBuilder |
replQueueInterval(long interval,
java.util.concurrent.TimeUnit unit)
If useReplQueue is set to true, this attribute controls how often the asynchronous thread used
to flush the replication queue runs.
|
AsyncConfigurationBuilder |
replQueueMaxElements(int elements)
If useReplQueue is set to true, this attribute can be used to trigger flushing of the queue
when it reaches a specific threshold.
|
AsyncConfigurationBuilder |
syncMarshalling()
Enables synchronous marshalling.
|
java.lang.String |
toString() |
AsyncConfigurationBuilder |
useReplQueue(boolean use)
If true, forces all async communications to be queued up and sent out periodically as a
batch.
|
void |
validate() |
async, getClusteringBuilder, hash, l1, stateTransfer, sync
build, clustering, compatibility, customInterceptors, dataContainer, deadlockDetection, eviction, expiration, getBuilder, indexing, invocationBatching, jmxStatistics, locking, persistence, sites, storeAsBinary, transaction, unsafe, versioning
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
build, clustering, compatibility, customInterceptors, dataContainer, deadlockDetection, eviction, expiration, indexing, invocationBatching, jmxStatistics, locking, persistence, sites, storeAsBinary, transaction, unsafe, versioning
private boolean asyncMarshalling
private org.infinispan.remoting.ReplicationQueue replicationQueue
private long replicationQueueInterval
private int replicationQueueMaxElements
private boolean useReplicationQueue
protected AsyncConfigurationBuilder(ClusteringConfigurationBuilder builder)
public AsyncConfigurationBuilder asyncMarshalling()
public AsyncConfigurationBuilder asyncMarshalling(boolean async)
public AsyncConfigurationBuilder syncMarshalling()
public AsyncConfigurationBuilder replQueue(org.infinispan.remoting.ReplicationQueue replicationQueue)
ReplicationQueueImpl
.
NOTE: Currently Infinispan will not use the object instance, but instead instantiate a new
instance of the class. Therefore, do not expect any state to survive, and provide a no-args
constructor to any instance. This will be resolved in Infinispan 5.2.0public AsyncConfigurationBuilder replQueueInterval(long interval)
public AsyncConfigurationBuilder replQueueInterval(long interval, java.util.concurrent.TimeUnit unit)
public AsyncConfigurationBuilder replQueueMaxElements(int elements)
public AsyncConfigurationBuilder useReplQueue(boolean use)
public void validate()
public AsyncConfiguration create()
public AsyncConfigurationBuilder read(AsyncConfiguration template)
public java.lang.String toString()
toString
in class java.lang.Object