com.j_spaces.core.cluster

Class ReplicationPolicy

java.lang.Object

com.j_spaces.core.cluster.ReplicationPolicy

All Implemented Interfaces:

Externalizable, Serializable

public class ReplicationPolicy
extends Object
implements Serializable, Externalizable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReplicationPolicy.ReplicationPolicyDescription Replication policy description for every member.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASYNC_REPLICATION_MODE
static String	BLOCK_OPERATIONS_MODE
String	clusterName the name of the cluster this replication policy belongs to
static long	DEFAULT_ASYNC_CHANNEL_SHUTDOWN_TIMEOUT
static String	DEFAULT_BACKLOG_WEIGHT_POLICY
static int	DEFAULT_BLOBSTORE_RECOVERY_THREAD_POOL_SIZE
static int	DEFAULT_CONNECTION_MONITOR_THREAD_POOL_SIZE
static float	DEFAULT_DISCARDED_PACKET_WEIGHT_LOAD_FACTOR
static long	DEFAULT_DURABLE_NOTIFICATION_MAX_DISCONNECTION_TIME
static long	DEFAULT_DURABLE_NOTIFICATION_REDOLOG_CAPACITY
static long	DEFAULT_LOCALVIEW_MAX_DISCONNECTION_TIME
static long	DEFAULT_LOCALVIEW_REDOLOG_CAPACITY
static long	DEFAULT_LOCALVIEW_REDOLOG_RECOVERY_CAPACITY
static long	DEFAULT_MAX_REDO_LOG_CPACITY
static String	DEFAULT_MIRROR_SERVICE_CONNECTOR_NAME
static String	DEFAULT_MIRROR_SERVICE_NAME
static MissingPacketsPolicy	DEFAULT_MISSING_PACKETS
static boolean	DEFAULT_OLD_MODULE
static ReplicationProcessingType	DEFAULT_PROCESSING_TYPE
static int	DEFAULT_RECOVERY_CHUNK_SIZE
static int	DEFAULT_RECOVERY_THREAD_POOL_SIZE
static RedoLogCapacityExceededPolicy	DEFAULT_REDO_LOG_CAPACITY_EXCEEDED
static RedoLogCompaction	DEFAULT_REDO_LOG_COMPACTION
static float	DEFAULT_REDO_LOG_COMPACTION_BATCH_SIZE
static long	DEFAULT_RELIABLE_ASYNC_STATE_NOTIFY_INTERVAL
static long	DEFAULT_RELIABLE_ASYNC_STATE_NOTIFY_PACKETS
static int	DEFAULT_REPL_CHUNK_SIZE
static boolean	DEFAULT_REPL_FULL_TAKE
static int	DEFAULT_REPL_INTERVAL_MILLIS
static int	DEFAULT_REPL_INTERVAL_OPERS
static boolean	DEFAULT_REPL_NETWORK_COMPRESSION
static String	DEFAULT_REPL_ORIGINAL_STATE
static int	DEFAULT_REPL_SPACE_FINDER_REPORT_INTERVAL
static int	DEFAULT_REPL_SPACE_FINDER_TIMEOUT
static boolean	DEFAULT_REPLICATE_ONE_PHASE_COMMIT
static int	DEFAULT_SYNC_ON_COMMIT_TIMEOUT
static String	DROP_OLDEST_MODE
static int	FULL_REPLICATION
static String	GLOBAL_ORDER_MODE
static String	IGNORE_MODE
boolean	isOneWayReplication fast one way replication
boolean	m_IsSyncReplicationEnabled true if sync-replication enabled, otherwise async-repl
String	m_OwnMemberName
int	m_PolicyType
boolean	m_Recovery
boolean	m_ReplicateNotifyTemplates
int	m_ReplicationChunkSize
List<String>	m_ReplicationGroupMembersNames
List<SpaceURL>	m_ReplicationGroupMembersURLs
String	m_ReplicationGroupName
long	m_ReplicationIntervalMillis
int	m_ReplicationIntervalOperations
String	m_ReplicationMode
boolean	m_ReplicationNetworkCompression
Hashtable<String,ReplicationPolicy.ReplicationPolicyDescription>	m_ReplMemberPolicyDescTable replication policy description table: key: memberName, value: ReplicationPolicyDescription.
long	m_SpaceFinderReportInterval
long	m_SpaceFinderTimeout
boolean	m_SyncOnCommit
long	m_SyncOnCommitTimeout
SyncReplPolicy	m_SyncReplPolicy group's sync-replication information, if null, not sync replication defined.
boolean	m_TriggerNotifyTemplates
static String	MULTI_BUCKET_MODE
static String	MULTI_SOURCE_MODE
static int	MULTICAST
static String	MULTICAST_COMMUNICATION_MODE
static int	PARTIAL_REPLICATION
static String	RECOVER_MODE
static String	SYNC_REC_ACK_REPLICATION_MODE
static String	SYNC_REPLICATION_MODE
static int	UNICAST
static String	UNICAST_COMMUNICATION_MODE

Constructor Summary

Constructors

Constructor and Description
ReplicationPolicy() Just for Externalizable.
ReplicationPolicy(String clusterName, String replicationGroupName, List<String> replicationGroupMembersNames, List<SpaceURL> replicationGroupMembersURLs, String ownMemberName, Hashtable<String,ReplicationPolicy.ReplicationPolicyDescription> replMemberPolicyDescTable, SyncReplPolicy syncReplPolicy, MultiBucketReplicationPolicy multiBucketReplicationPolicy, SwapBacklogConfig swapRedologPolicy)

Method Summary

Modifier and Type	Method and Description
long	getAsyncChannelShutdownTimeout()
String	getBacklogWeightPolicy()
ConflictingOperationPolicy	getConflictingOperationPolicy()
int	getConnectionMonitorThreadPoolSize()
long	getDurableNotificationMaxDisconnectionTime()
long	getDurableNotificationMaxRedologCapacity()
long	getLocalViewMaxDisconnectionTime()
long	getLocalViewMaxRedologCapacity()
long	getLocalViewMaxRedologRecoveryCapacity()
long	getMaxRedoLogCapacity()
long	getMaxRedoLogMemoryCapacity()
long	getMaxRedoLogRecoveryCapacity()
MirrorServiceConfig	getMirrorServiceConfig()
MultiBucketReplicationPolicy	getMultiBucketReplicationPolicy()
MissingPacketsPolicy	getOnMissingPackets()
RedoLogCapacityExceededPolicy	getOnRedoLogCapacityExceeded()
LeaderSelector	getPrimarySpaceSelector()
List<SpaceURL>	getPrimaryTargets(List<String> excludeTargets) Returns a list of URLs or an empty list of primary targets .
ReplicationProcessingType	getProcessingType()
List<SpaceURL>	getRecoverableTargets(List<String> excludeTargets) Finds all the recovery targets in cluster.
int	getRecoveryChunkSize()
int	getRecoveryThreadPoolSize()
RedoLogCompaction	getRedoLogCompaction()
long	getReliableAsyncCompletionNotifierInterval()
long	getReliableAsyncCompletionNotifierPacketsThreshold()
int	getReplicationTargetsCount()
int	getSpaceMemberPosition(String spaceMemberName) This method returns the relative position of the specified space member in the replication group, or -1 if the space member is not found.
SpaceURL	getSpaceReplicationUrl(String fullSpaceName)
SwapBacklogConfig	getSwapRedologPolicy()
List<SpaceURL>	getSyncTargets(List<String> excludeTargets) Returns a list of URLs or an empty list of reliable targets to recover from.
boolean	isFullReplication()
boolean	isMirrorServiceEnabled()
boolean	isNetworkCompressionEnabled()
boolean	isOwnerMemberHasSyncReplication() returns true if this member has sync-replication to at least one target.
boolean	isReliableAsyncRepl()
boolean	isReplicateFullTake()
boolean	isReplicateLeaseExpirations()
boolean	isReplicateOnePhaseCommit()
boolean	isReplicateOriginalState()
void	readExternal(ObjectInput in)
void	setAsyncChannelShutdownTimeout(long shutdownTimeout)
void	setBacklogWeightPolicy(String backlogWeightPolicy)
void	setConflictingOperationPolicy(ConflictingOperationPolicy conflictingOperationPolicy)
void	setConnectionMonitorThreadPoolSize(int connectionMonitorThreadPoolSize)
void	setDurableNotificationMaxDisconnectionTime(long notificationMaxDisconnectionTime)
void	setDurableNotificationMaxRedologCapacity(Long notificationMaxRedologCapacity)
void	setLocalViewMaxDisconnectionTime(long localViewMaxDisconnectionTime)
void	setLocalViewMaxRedologCapacity(Long localViewMaxRedologCapacity)
void	setLocalViewMaxRedologRecoveryCapacity(Long localViewMaxRedologRecoveryCapacity)
void	setMaxRedoLogCapacity(long capacity)
void	setMaxRedoLogMemoryCapacity(long capacity)
void	setMaxRedoLogRecoveryCapacity(long capacity)
void	setMirrorServiceConfig(MirrorServiceConfig mirrorServiceConfig)
void	setOnMissingPackets(MissingPacketsPolicy onMissingPackets)
void	setOnRedoLogCapacityExceeded(RedoLogCapacityExceededPolicy policy)
void	setPermittedOperations(List<ReplicationOperationType> permittedOperations)
void	setPrimarySpaceSelector(LeaderSelector primarySpaceSelector)
void	setProcessingType(ReplicationProcessingType processingType)
void	setRecoveryChunkSize(int recoveryChunkSize)
void	setRecoveryThreadPoolSize(int recoveryThreadPoolSize)
void	setRedoLogCompaction(RedoLogCompaction redoLogCompaction)
void	setReliableAsyncCompletionNotifierInterval(long reliableAsyncCompletionNotifierInterval)
void	setReliableAsyncCompletionNotifierPacketsThreshold(long reliableAsyncCompletionNotifierPacketsThreshold)
void	setReliableAsyncRepl(boolean reliableAsyncRepl) Sets the async-replication 'reliable' indicator; default false
void	setReplicatedOriginalState(boolean isReplOriginalState)
void	setReplicateFullTake(boolean replicateFullTake)
void	setReplicateLeaseExpirations(boolean value)
void	setReplicateOnePhaseCommit(boolean replicateOnePhaseCommit)
boolean	shouldReplicate(ReplicationOperationType operType)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

UNICAST_COMMUNICATION_MODE

public static final String UNICAST_COMMUNICATION_MODE

See Also:

Constant Field Values

MULTICAST_COMMUNICATION_MODE

public static final String MULTICAST_COMMUNICATION_MODE

See Also:

Constant Field Values

UNICAST

public static final int UNICAST

See Also:

Constant Field Values

MULTICAST

public static final int MULTICAST

See Also:

Constant Field Values

ASYNC_REPLICATION_MODE

public static final String ASYNC_REPLICATION_MODE

See Also:

Constant Field Values

SYNC_REPLICATION_MODE

public static final String SYNC_REPLICATION_MODE

See Also:

Constant Field Values

SYNC_REC_ACK_REPLICATION_MODE

public static final String SYNC_REC_ACK_REPLICATION_MODE

See Also:

Constant Field Values

BLOCK_OPERATIONS_MODE

public static final String BLOCK_OPERATIONS_MODE

See Also:

Constant Field Values

DROP_OLDEST_MODE

public static final String DROP_OLDEST_MODE

See Also:

Constant Field Values

RECOVER_MODE

public static final String RECOVER_MODE

See Also:

Constant Field Values

IGNORE_MODE

public static final String IGNORE_MODE

See Also:

Constant Field Values

GLOBAL_ORDER_MODE

public static final String GLOBAL_ORDER_MODE

See Also:

Constant Field Values

MULTI_BUCKET_MODE

public static final String MULTI_BUCKET_MODE

See Also:

Constant Field Values

MULTI_SOURCE_MODE

public static final String MULTI_SOURCE_MODE

See Also:

Constant Field Values

FULL_REPLICATION

public static final int FULL_REPLICATION

See Also:

Constant Field Values

PARTIAL_REPLICATION

public static final int PARTIAL_REPLICATION

See Also:

Constant Field Values

DEFAULT_REPL_ORIGINAL_STATE

public static final String DEFAULT_REPL_ORIGINAL_STATE

See Also:

Constant Field Values

DEFAULT_REPL_CHUNK_SIZE

public static final int DEFAULT_REPL_CHUNK_SIZE

See Also:

Constant Field Values

DEFAULT_REPL_INTERVAL_MILLIS

public static final int DEFAULT_REPL_INTERVAL_MILLIS

See Also:

Constant Field Values

DEFAULT_REPL_INTERVAL_OPERS

public static final int DEFAULT_REPL_INTERVAL_OPERS

See Also:

Constant Field Values

DEFAULT_REPL_SPACE_FINDER_TIMEOUT

public static final int DEFAULT_REPL_SPACE_FINDER_TIMEOUT

See Also:

Constant Field Values

DEFAULT_REPL_SPACE_FINDER_REPORT_INTERVAL

public static final int DEFAULT_REPL_SPACE_FINDER_REPORT_INTERVAL

See Also:

Constant Field Values

DEFAULT_SYNC_ON_COMMIT_TIMEOUT

public static final int DEFAULT_SYNC_ON_COMMIT_TIMEOUT

See Also:

Constant Field Values

DEFAULT_ASYNC_CHANNEL_SHUTDOWN_TIMEOUT

public static final long DEFAULT_ASYNC_CHANNEL_SHUTDOWN_TIMEOUT

See Also:

Constant Field Values

DEFAULT_REPL_NETWORK_COMPRESSION

public static final boolean DEFAULT_REPL_NETWORK_COMPRESSION

See Also:

Constant Field Values

DEFAULT_MAX_REDO_LOG_CPACITY

public static final long DEFAULT_MAX_REDO_LOG_CPACITY

See Also:

Constant Field Values

DEFAULT_REDO_LOG_CAPACITY_EXCEEDED

public static final RedoLogCapacityExceededPolicy DEFAULT_REDO_LOG_CAPACITY_EXCEEDED

DEFAULT_RECOVERY_CHUNK_SIZE

public static final int DEFAULT_RECOVERY_CHUNK_SIZE

See Also:

Constant Field Values

DEFAULT_RECOVERY_THREAD_POOL_SIZE

public static final int DEFAULT_RECOVERY_THREAD_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_BLOBSTORE_RECOVERY_THREAD_POOL_SIZE

public static final int DEFAULT_BLOBSTORE_RECOVERY_THREAD_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_MISSING_PACKETS

public static final MissingPacketsPolicy DEFAULT_MISSING_PACKETS

DEFAULT_REPL_FULL_TAKE

public static final boolean DEFAULT_REPL_FULL_TAKE

See Also:

Constant Field Values

DEFAULT_OLD_MODULE

public static final boolean DEFAULT_OLD_MODULE

See Also:

Constant Field Values

DEFAULT_PROCESSING_TYPE

public static final ReplicationProcessingType DEFAULT_PROCESSING_TYPE

DEFAULT_LOCALVIEW_REDOLOG_CAPACITY

public static final long DEFAULT_LOCALVIEW_REDOLOG_CAPACITY

See Also:

Constant Field Values

DEFAULT_LOCALVIEW_MAX_DISCONNECTION_TIME

public static final long DEFAULT_LOCALVIEW_MAX_DISCONNECTION_TIME

See Also:

Constant Field Values

DEFAULT_LOCALVIEW_REDOLOG_RECOVERY_CAPACITY

public static final long DEFAULT_LOCALVIEW_REDOLOG_RECOVERY_CAPACITY

See Also:

Constant Field Values

DEFAULT_DURABLE_NOTIFICATION_REDOLOG_CAPACITY

public static final long DEFAULT_DURABLE_NOTIFICATION_REDOLOG_CAPACITY

See Also:

Constant Field Values

DEFAULT_DURABLE_NOTIFICATION_MAX_DISCONNECTION_TIME

public static final long DEFAULT_DURABLE_NOTIFICATION_MAX_DISCONNECTION_TIME

See Also:

Constant Field Values

DEFAULT_RELIABLE_ASYNC_STATE_NOTIFY_INTERVAL

public static final long DEFAULT_RELIABLE_ASYNC_STATE_NOTIFY_INTERVAL

See Also:

Constant Field Values

DEFAULT_RELIABLE_ASYNC_STATE_NOTIFY_PACKETS

public static final long DEFAULT_RELIABLE_ASYNC_STATE_NOTIFY_PACKETS

See Also:

Constant Field Values

DEFAULT_REPLICATE_ONE_PHASE_COMMIT

public static final boolean DEFAULT_REPLICATE_ONE_PHASE_COMMIT

See Also:

Constant Field Values

DEFAULT_CONNECTION_MONITOR_THREAD_POOL_SIZE

public static final int DEFAULT_CONNECTION_MONITOR_THREAD_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_BACKLOG_WEIGHT_POLICY

public static final String DEFAULT_BACKLOG_WEIGHT_POLICY

See Also:

Constant Field Values

DEFAULT_REDO_LOG_COMPACTION

public static final RedoLogCompaction DEFAULT_REDO_LOG_COMPACTION

DEFAULT_DISCARDED_PACKET_WEIGHT_LOAD_FACTOR

public static final float DEFAULT_DISCARDED_PACKET_WEIGHT_LOAD_FACTOR

DEFAULT_REDO_LOG_COMPACTION_BATCH_SIZE

public static final float DEFAULT_REDO_LOG_COMPACTION_BATCH_SIZE

m_OwnMemberName

public String m_OwnMemberName

m_ReplicationGroupName

public String m_ReplicationGroupName

m_ReplicationGroupMembersNames

public List<String> m_ReplicationGroupMembersNames

m_ReplicationGroupMembersURLs

public List<SpaceURL> m_ReplicationGroupMembersURLs

m_ReplicateNotifyTemplates

public boolean m_ReplicateNotifyTemplates

m_TriggerNotifyTemplates

public boolean m_TriggerNotifyTemplates

m_SyncOnCommit

public boolean m_SyncOnCommit

m_ReplicationMode

public String m_ReplicationMode

m_PolicyType

public int m_PolicyType

m_ReplicationChunkSize

public int m_ReplicationChunkSize

m_ReplicationIntervalMillis

public long m_ReplicationIntervalMillis

m_ReplicationIntervalOperations

public int m_ReplicationIntervalOperations

m_SpaceFinderTimeout

public long m_SpaceFinderTimeout

m_SpaceFinderReportInterval

public long m_SpaceFinderReportInterval

m_SyncOnCommitTimeout

public long m_SyncOnCommitTimeout

m_ReplicationNetworkCompression

public boolean m_ReplicationNetworkCompression

m_Recovery

public boolean m_Recovery

m_ReplMemberPolicyDescTable

public Hashtable<String,ReplicationPolicy.ReplicationPolicyDescription> m_ReplMemberPolicyDescTable

replication policy description table: key: memberName, value: ReplicationPolicyDescription.

isOneWayReplication

public boolean isOneWayReplication

fast one way replication

m_IsSyncReplicationEnabled

public boolean m_IsSyncReplicationEnabled

true if sync-replication enabled, otherwise async-repl

m_SyncReplPolicy

public SyncReplPolicy m_SyncReplPolicy

group's sync-replication information, if null, not sync replication defined.

clusterName

public String clusterName

the name of the cluster this replication policy belongs to

DEFAULT_MIRROR_SERVICE_NAME

public static final String DEFAULT_MIRROR_SERVICE_NAME

See Also:

Constant Field Values

DEFAULT_MIRROR_SERVICE_CONNECTOR_NAME

public static final String DEFAULT_MIRROR_SERVICE_CONNECTOR_NAME

See Also:

Constant Field Values

Constructor Detail

ReplicationPolicy

public ReplicationPolicy()

Just for Externalizable.

ReplicationPolicy

public ReplicationPolicy(String clusterName,
                         String replicationGroupName,
                         List<String> replicationGroupMembersNames,
                         List<SpaceURL> replicationGroupMembersURLs,
                         String ownMemberName,
                         Hashtable<String,ReplicationPolicy.ReplicationPolicyDescription> replMemberPolicyDescTable,
                         SyncReplPolicy syncReplPolicy,
                         MultiBucketReplicationPolicy multiBucketReplicationPolicy,
                         SwapBacklogConfig swapRedologPolicy)

Method Detail

setRedoLogCompaction

public void setRedoLogCompaction(RedoLogCompaction redoLogCompaction)

getRedoLogCompaction

public RedoLogCompaction getRedoLogCompaction()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

setMirrorServiceConfig

public void setMirrorServiceConfig(MirrorServiceConfig mirrorServiceConfig)

getMirrorServiceConfig

public MirrorServiceConfig getMirrorServiceConfig()

Returns:

null if the mirror-service disabled

isMirrorServiceEnabled

public boolean isMirrorServiceEnabled()

Returns:

if the mirror service enabled for entire replication group

isReliableAsyncRepl

public boolean isReliableAsyncRepl()

Returns:

the async-replication 'reliable' indicator; default false

shouldReplicate

public boolean shouldReplicate(ReplicationOperationType operType)

setPermittedOperations

public void setPermittedOperations(List<ReplicationOperationType> permittedOperations)

setReliableAsyncRepl

public void setReliableAsyncRepl(boolean reliableAsyncRepl)

Sets the async-replication 'reliable' indicator; default false

Parameters:

reliableAsyncRepl - true if reliable-async-replication is enabled; false otherwise.

setMaxRedoLogCapacity

public void setMaxRedoLogCapacity(long capacity)

getMaxRedoLogCapacity

public long getMaxRedoLogCapacity()

setMaxRedoLogMemoryCapacity

public void setMaxRedoLogMemoryCapacity(long capacity)

setBacklogWeightPolicy

public void setBacklogWeightPolicy(String backlogWeightPolicy)

getMaxRedoLogMemoryCapacity

public long getMaxRedoLogMemoryCapacity()

getBacklogWeightPolicy

public String getBacklogWeightPolicy()

getMaxRedoLogRecoveryCapacity

public long getMaxRedoLogRecoveryCapacity()

setMaxRedoLogRecoveryCapacity

public void setMaxRedoLogRecoveryCapacity(long capacity)

setLocalViewMaxRedologCapacity

public void setLocalViewMaxRedologCapacity(Long localViewMaxRedologCapacity)

getLocalViewMaxRedologCapacity

public long getLocalViewMaxRedologCapacity()

setLocalViewMaxDisconnectionTime

public void setLocalViewMaxDisconnectionTime(long localViewMaxDisconnectionTime)

getLocalViewMaxDisconnectionTime

public long getLocalViewMaxDisconnectionTime()

setLocalViewMaxRedologRecoveryCapacity

public void setLocalViewMaxRedologRecoveryCapacity(Long localViewMaxRedologRecoveryCapacity)

getLocalViewMaxRedologRecoveryCapacity

public long getLocalViewMaxRedologRecoveryCapacity()

setOnRedoLogCapacityExceeded

public void setOnRedoLogCapacityExceeded(RedoLogCapacityExceededPolicy policy)

getOnRedoLogCapacityExceeded

public RedoLogCapacityExceededPolicy getOnRedoLogCapacityExceeded()

isOwnerMemberHasSyncReplication

public boolean isOwnerMemberHasSyncReplication()

returns true if this member has sync-replication to at least one target.

setPrimarySpaceSelector

public void setPrimarySpaceSelector(LeaderSelector primarySpaceSelector)

getPrimarySpaceSelector

public LeaderSelector getPrimarySpaceSelector()

getRecoverableTargets

public List<SpaceURL> getRecoverableTargets(List<String> excludeTargets)

Finds all the recovery targets in cluster. The targets are ordered according to their reliability. First all primary targets are added. Then the sync targets, and only then all the others.

Parameters:

excludeTargets - targets that should be excluded from search

Returns:

a list of recoverable members SpaceURLs. returns empty list if recovery is disabled.

getSyncTargets

public List<SpaceURL> getSyncTargets(List<String> excludeTargets)

Returns a list of URLs or an empty list of reliable targets to recover from. A 'reliable' target is one that replicates synchronously to 'this' source.

This differs from getRecoverableTargets(java.util.List) in that:
1. all URLs are returned and there is no multicast URL - We need specific members.
2. The target is chosen only if it sync-replicates to 'this', in contrast to returning a target which 'this' replicates to.

Returns:

a list of URLs or an empty list of reliable targets to recover from. Never returns null.

getPrimaryTargets

public List<SpaceURL> getPrimaryTargets(List<String> excludeTargets)

Returns a list of URLs or an empty list of primary targets .

Returns:

a list of URLs or an empty list of primary targets. Never returns null.

getSpaceMemberPosition

public int getSpaceMemberPosition(String spaceMemberName)

This method returns the relative position of the specified space member in the replication group, or -1 if the space member is not found. Positions are counted from 0 to #nodes - 1. The position can be used as a unique identifier of the space within its group.

getRecoveryChunkSize

public final int getRecoveryChunkSize()

setRecoveryChunkSize

public void setRecoveryChunkSize(int recoveryChunkSize)

isReplicateOriginalState

public final boolean isReplicateOriginalState()

setReplicatedOriginalState

public void setReplicatedOriginalState(boolean isReplOriginalState)

getConflictingOperationPolicy

public ConflictingOperationPolicy getConflictingOperationPolicy()

setConflictingOperationPolicy

public void setConflictingOperationPolicy(ConflictingOperationPolicy conflictingOperationPolicy)

toString

public String toString()

Overrides:

toString in class Object

getRecoveryThreadPoolSize

public int getRecoveryThreadPoolSize()

setRecoveryThreadPoolSize

public void setRecoveryThreadPoolSize(int recoveryThreadPoolSize)

getAsyncChannelShutdownTimeout

public long getAsyncChannelShutdownTimeout()

setAsyncChannelShutdownTimeout

public void setAsyncChannelShutdownTimeout(long shutdownTimeout)

setOnMissingPackets

public void setOnMissingPackets(MissingPacketsPolicy onMissingPackets)

getOnMissingPackets

public MissingPacketsPolicy getOnMissingPackets()

setReplicateFullTake

public void setReplicateFullTake(boolean replicateFullTake)

isReplicateFullTake

public boolean isReplicateFullTake()

getSpaceReplicationUrl

public SpaceURL getSpaceReplicationUrl(String fullSpaceName)

getProcessingType

public ReplicationProcessingType getProcessingType()

setProcessingType

public void setProcessingType(ReplicationProcessingType processingType)

getMultiBucketReplicationPolicy

public MultiBucketReplicationPolicy getMultiBucketReplicationPolicy()

getSwapRedologPolicy

public SwapBacklogConfig getSwapRedologPolicy()

isFullReplication

public boolean isFullReplication()

isReplicateLeaseExpirations

public boolean isReplicateLeaseExpirations()

setReplicateLeaseExpirations

public void setReplicateLeaseExpirations(boolean value)

getReplicationTargetsCount

public int getReplicationTargetsCount()

setReliableAsyncCompletionNotifierInterval

public void setReliableAsyncCompletionNotifierInterval(long reliableAsyncCompletionNotifierInterval)

getReliableAsyncCompletionNotifierInterval

public long getReliableAsyncCompletionNotifierInterval()

getReliableAsyncCompletionNotifierPacketsThreshold

public long getReliableAsyncCompletionNotifierPacketsThreshold()

setReliableAsyncCompletionNotifierPacketsThreshold

public void setReliableAsyncCompletionNotifierPacketsThreshold(long reliableAsyncCompletionNotifierPacketsThreshold)

isReplicateOnePhaseCommit

public boolean isReplicateOnePhaseCommit()

setReplicateOnePhaseCommit

public void setReplicateOnePhaseCommit(boolean replicateOnePhaseCommit)

getDurableNotificationMaxRedologCapacity

public long getDurableNotificationMaxRedologCapacity()

setDurableNotificationMaxRedologCapacity

public void setDurableNotificationMaxRedologCapacity(Long notificationMaxRedologCapacity)

getDurableNotificationMaxDisconnectionTime

public long getDurableNotificationMaxDisconnectionTime()

setDurableNotificationMaxDisconnectionTime

public void setDurableNotificationMaxDisconnectionTime(long notificationMaxDisconnectionTime)

setConnectionMonitorThreadPoolSize

public void setConnectionMonitorThreadPoolSize(int connectionMonitorThreadPoolSize)

getConnectionMonitorThreadPoolSize

public int getConnectionMonitorThreadPoolSize()

isNetworkCompressionEnabled

public boolean isNetworkCompressionEnabled()