GigaSpaces XAP 10.0.1 API

com.j_spaces.core.cluster
Class ReplicationPolicy

java.lang.Object
  extended by 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
static class ReplicationPolicy.ReplicationPolicyDescription
          Replication policy description for every member.
 
Field Summary
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 int DEFAULT_BLOBSTORE_RECOVERY_THREAD_POOL_SIZE
           
static int DEFAULT_CONNECTION_MONITOR_THREAD_POOL_SIZE
           
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 com.j_spaces.core.cluster.MissingPacketsPolicy DEFAULT_MISSING_PACKETS
           
static boolean DEFAULT_OLD_MODULE
           
static com.j_spaces.core.cluster.ReplicationProcessingType DEFAULT_PROCESSING_TYPE
           
static int DEFAULT_RECOVERY_CHUNK_SIZE
           
static int DEFAULT_RECOVERY_THREAD_POOL_SIZE
           
static com.j_spaces.core.cluster.RedoLogCapacityExceededPolicy DEFAULT_REDO_LOG_CAPACITY_EXCEEDED
           
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 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
           
 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
           
 com.gigaspaces.cluster.replication.sync.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
ReplicationPolicy()
          Just for Externalizable.
ReplicationPolicy(String clusterName, String replicationGroupName, List<String> replicationGroupMembersNames, List<SpaceURL> replicationGroupMembersURLs, String ownMemberName, Hashtable<String,ReplicationPolicy.ReplicationPolicyDescription> replMemberPolicyDescTable, com.gigaspaces.cluster.replication.sync.SyncReplPolicy syncReplPolicy, com.gigaspaces.internal.cluster.node.impl.config.MultiBucketReplicationPolicy multiBucketReplicationPolicy, com.j_spaces.core.cluster.SwapBacklogConfig swapRedologPolicy)
           
 
Method Summary
 long getAsyncChannelShutdownTimeout()
           
 com.j_spaces.core.cluster.ConflictingOperationPolicy getConflictingOperationPolicy()
           
 int getConnectionMonitorThreadPoolSize()
           
 long getDurableNotificationMaxDisconnectionTime()
           
 long getDurableNotificationMaxRedologCapacity()
           
 com.gigaspaces.internal.cluster.node.impl.gateway.GatewaysPolicy getGatewaysPolicy()
           
 long getLocalViewMaxDisconnectionTime()
           
 long getLocalViewMaxRedologCapacity()
           
 long getLocalViewMaxRedologRecoveryCapacity()
           
 long getMaxRedoLogCapacity()
           
 long getMaxRedoLogMemoryCapacity()
           
 long getMaxRedoLogRecoveryCapacity()
           
 com.gigaspaces.cluster.replication.MirrorServiceConfig getMirrorServiceConfig()
           
 com.gigaspaces.internal.cluster.node.impl.config.MultiBucketReplicationPolicy getMultiBucketReplicationPolicy()
           
 com.j_spaces.core.cluster.MissingPacketsPolicy getOnMissingPackets()
           
 com.j_spaces.core.cluster.RedoLogCapacityExceededPolicy getOnRedoLogCapacityExceeded()
           
 com.gigaspaces.cluster.activeelection.PrimarySpaceSelector getPrimarySpaceSelector()
           
 List<SpaceURL> getPrimaryTargets(List<String> excludeTargets)
          Returns a list of URLs or an empty list of primary targets .
 com.j_spaces.core.cluster.ReplicationProcessingType getProcessingType()
           
 List<SpaceURL> getRecoverableTargets(List<String> excludeTargets)
          Finds all the recovery targets in cluster.
 int getRecoveryChunkSize()
           
 int getRecoveryThreadPoolSize()
           
 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)
           
 com.j_spaces.core.cluster.SwapBacklogConfig getSwapRedologPolicy()
           
 List<SpaceURL> getSyncTargets(List<String> excludeTargets)
          Returns a list of URLs or an empty list of reliable targets to recover from.
 boolean hasReplicationGateways()
           
 boolean isFullReplication()
           
 boolean isMirrorServiceEnabled()
           
 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 setConflictingOperationPolicy(com.j_spaces.core.cluster.ConflictingOperationPolicy conflictingOperationPolicy)
           
 void setConnectionMonitorThreadPoolSize(int connectionMonitorThreadPoolSize)
           
 void setDurableNotificationMaxDisconnectionTime(long notificationMaxDisconnectionTime)
           
 void setDurableNotificationMaxRedologCapacity(Long notificationMaxRedologCapacity)
           
 void setGatewaysPolicy(com.gigaspaces.internal.cluster.node.impl.gateway.GatewaysPolicy gatewaysPolicy)
           
 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(com.gigaspaces.cluster.replication.MirrorServiceConfig mirrorServiceConfig)
           
 void setOnMissingPackets(com.j_spaces.core.cluster.MissingPacketsPolicy onMissingPackets)
           
 void setOnRedoLogCapacityExceeded(com.j_spaces.core.cluster.RedoLogCapacityExceededPolicy policy)
           
 void setPermittedOperations(List<ReplicationOperationType> permittedOperations)
           
 void setPrimarySpaceSelector(com.gigaspaces.cluster.activeelection.PrimarySpaceSelector primarySpaceSelector)
           
 void setProcessingType(com.j_spaces.core.cluster.ReplicationProcessingType processingType)
           
 void setRecoveryChunkSize(int recoveryChunkSize)
           
 void setRecoveryThreadPoolSize(int recoveryThreadPoolSize)
           
 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_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 com.j_spaces.core.cluster.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 com.j_spaces.core.cluster.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 com.j_spaces.core.cluster.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

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_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 com.gigaspaces.cluster.replication.sync.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,
                         com.gigaspaces.cluster.replication.sync.SyncReplPolicy syncReplPolicy,
                         com.gigaspaces.internal.cluster.node.impl.config.MultiBucketReplicationPolicy multiBucketReplicationPolicy,
                         com.j_spaces.core.cluster.SwapBacklogConfig swapRedologPolicy)
Method Detail

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(com.gigaspaces.cluster.replication.MirrorServiceConfig mirrorServiceConfig)

getMirrorServiceConfig

public com.gigaspaces.cluster.replication.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)

getMaxRedoLogMemoryCapacity

public long getMaxRedoLogMemoryCapacity()

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(com.j_spaces.core.cluster.RedoLogCapacityExceededPolicy policy)

getOnRedoLogCapacityExceeded

public com.j_spaces.core.cluster.RedoLogCapacityExceededPolicy getOnRedoLogCapacityExceeded()

isOwnerMemberHasSyncReplication

public boolean isOwnerMemberHasSyncReplication()
returns true if this member has sync-replication to at least one target.


setPrimarySpaceSelector

public void setPrimarySpaceSelector(com.gigaspaces.cluster.activeelection.PrimarySpaceSelector primarySpaceSelector)

getPrimarySpaceSelector

public com.gigaspaces.cluster.activeelection.PrimarySpaceSelector 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.

Parameters:
excludeTargets -
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 .

Parameters:
excludeTargets -
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 com.j_spaces.core.cluster.ConflictingOperationPolicy getConflictingOperationPolicy()

setConflictingOperationPolicy

public void setConflictingOperationPolicy(com.j_spaces.core.cluster.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(com.j_spaces.core.cluster.MissingPacketsPolicy onMissingPackets)

getOnMissingPackets

public com.j_spaces.core.cluster.MissingPacketsPolicy getOnMissingPackets()

setReplicateFullTake

public void setReplicateFullTake(boolean replicateFullTake)

isReplicateFullTake

public boolean isReplicateFullTake()

getSpaceReplicationUrl

public SpaceURL getSpaceReplicationUrl(String fullSpaceName)

getProcessingType

public com.j_spaces.core.cluster.ReplicationProcessingType getProcessingType()

setProcessingType

public void setProcessingType(com.j_spaces.core.cluster.ReplicationProcessingType processingType)

getMultiBucketReplicationPolicy

public com.gigaspaces.internal.cluster.node.impl.config.MultiBucketReplicationPolicy getMultiBucketReplicationPolicy()

getSwapRedologPolicy

public com.j_spaces.core.cluster.SwapBacklogConfig getSwapRedologPolicy()

getGatewaysPolicy

public com.gigaspaces.internal.cluster.node.impl.gateway.GatewaysPolicy getGatewaysPolicy()

setGatewaysPolicy

public void setGatewaysPolicy(com.gigaspaces.internal.cluster.node.impl.gateway.GatewaysPolicy gatewaysPolicy)

hasReplicationGateways

public boolean hasReplicationGateways()

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()

GigaSpaces XAP 10.0.1 API

Copyright © GigaSpaces.