net.sf.ehcache.distribution
Class RMICacheReplicatorFactory

java.lang.Object
  net.sf.ehcache.event.CacheEventListenerFactory
      net.sf.ehcache.distribution.RMICacheReplicatorFactory

public class RMICacheReplicatorFactory
extends CacheEventListenerFactory

Creates an RMICacheReplicator using properties. Config lines look like:

<cacheEventListenerFactory class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"
 properties="
 replicateAsynchronously=true,
 replicatePuts=true
 replicateUpdates=true
 replicateUpdatesViaCopy=true
 replicateRemovals=true
 "/>

Version:

$Id: RMICacheReplicatorFactory.java 5594 2012-05-07 16:04:31Z cdennis $

Author:

Greg Luck

Field Summary

protected static int	DEFAULT_ASYNCHRONOUS_REPLICATION_INTERVAL_MILLIS A default for the amount of time the replication thread sleeps after it detects the replicationQueue is empty before checking again.
protected static int	DEFAULT_ASYNCHRONOUS_REPLICATION_MAXIMUM_BATCH_SIZE A default for the maximum number of operations in an RMI message.

Constructor Summary

RMICacheReplicatorFactory()

Method Summary

CacheEventListener	createCacheEventListener(Properties properties) Create a CacheEventListener which is also a CacheReplicator.
protected int	extractMaximumBatchSize(Properties properties) Extracts the value of maximumBatchSize.
protected boolean	extractReplicateAsynchronously(Properties properties) Extracts the value of replicateAsynchronously from the properties
protected boolean	extractReplicatePuts(Properties properties) Extracts the value of replicatePuts from the properties
protected boolean	extractReplicatePutsViaCopy(Properties properties) Extracts the value of replicatePutsViaCopy from the properties
protected boolean	extractReplicateRemovals(Properties properties) Extracts the value of replicateRemovals from the properties
protected boolean	extractReplicateUpdates(Properties properties) Extracts the value of replicateUpdates from the properties
protected boolean	extractReplicateUpdatesViaCopy(Properties properties) Extracts the value of replicateUpdatesViaCopy from the properties
protected int	extractReplicationIntervalMilis(Properties properties) Extracts the value of asynchronousReplicationIntervalMillis.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_ASYNCHRONOUS_REPLICATION_INTERVAL_MILLIS

protected static final int DEFAULT_ASYNCHRONOUS_REPLICATION_INTERVAL_MILLIS

A default for the amount of time the replication thread sleeps after it detects the replicationQueue is empty before checking again.

See Also:

Constant Field Values

DEFAULT_ASYNCHRONOUS_REPLICATION_MAXIMUM_BATCH_SIZE

protected static final int DEFAULT_ASYNCHRONOUS_REPLICATION_MAXIMUM_BATCH_SIZE

A default for the maximum number of operations in an RMI message.

See Also:

Constant Field Values

Constructor Detail

RMICacheReplicatorFactory

public RMICacheReplicatorFactory()

Method Detail

createCacheEventListener

public final CacheEventListener createCacheEventListener(Properties properties)

Create a CacheEventListener which is also a CacheReplicator.

The defaults if properties are not specified are:

• replicatePuts=true
• replicatePutsViaCopy=true
• replicateUpdates=true
• replicateUpdatesViaCopy=true
• replicateRemovals=true;
• replicateAsynchronously=true
• asynchronousReplicationIntervalMillis=1000

Specified by:

createCacheEventListener in class CacheEventListenerFactory

Parameters:

properties - implementation specific properties. These are configured as comma separated name value pairs in ehcache.xml e.g.

<cacheEventListenerFactory class="net.sf.ehcache.distribution.RMICacheReplicatorFactory" properties=" replicateAsynchronously=true, replicatePuts=true replicateUpdates=true replicateUpdatesViaCopy=true replicateRemovals=true asynchronousReplicationIntervalMillis=1000 "/>

Returns:

a constructed CacheEventListener

extractReplicationIntervalMilis

protected int extractReplicationIntervalMilis(Properties properties)

Extracts the value of asynchronousReplicationIntervalMillis. Sets it to 1000ms if either not set or there is a problem parsing the number

Parameters:

properties -

extractMaximumBatchSize

protected int extractMaximumBatchSize(Properties properties)

Extracts the value of maximumBatchSize. Sets it to 1024 if either not set or there is a problem parsing the number

Parameters:

properties -

extractReplicateAsynchronously

protected boolean extractReplicateAsynchronously(Properties properties)

Extracts the value of replicateAsynchronously from the properties

Parameters:

properties -

extractReplicateRemovals

protected boolean extractReplicateRemovals(Properties properties)

Extracts the value of replicateRemovals from the properties

Parameters:

properties -

extractReplicateUpdatesViaCopy

protected boolean extractReplicateUpdatesViaCopy(Properties properties)

Extracts the value of replicateUpdatesViaCopy from the properties

Parameters:

properties -

extractReplicatePutsViaCopy

protected boolean extractReplicatePutsViaCopy(Properties properties)

Extracts the value of replicatePutsViaCopy from the properties

Parameters:

properties -

extractReplicateUpdates

protected boolean extractReplicateUpdates(Properties properties)

Extracts the value of replicateUpdates from the properties

Parameters:

properties -

extractReplicatePuts

protected boolean extractReplicatePuts(Properties properties)

Extracts the value of replicatePuts from the properties

Parameters:

properties -