com.hazelcast.enterprise.wan.replication

Class WanReplicationProperties

java.lang.Object

com.hazelcast.enterprise.wan.replication.WanReplicationProperties

public final class WanReplicationProperties
extends Object

Property definitions for WanBatchReplication implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static com.hazelcast.config.properties.PropertyDefinition	ACK_TYPE Determines acknowledgement waiting type of WAN replication operation invocation.
static com.hazelcast.config.properties.PropertyDefinition	BATCH_MAX_DELAY_MILLIS Defines the maximum amount of time to be waited before sending a batch of events to target cluster, if BATCH_SIZE of events have not arrived within this duration.
static com.hazelcast.config.properties.PropertyDefinition	BATCH_SIZE Defines the maximum batch size that can be sent to target cluster.
static com.hazelcast.config.properties.PropertyDefinition	DISCOVERY_PERIOD Period in seconds in which WAN tries to discover new endpoints and reestablish connections to failed endpoints.
static com.hazelcast.config.properties.PropertyDefinition	DISCOVERY_USE_ENDPOINT_PRIVATE_ADDRESS Determines whether the WAN connection manager should connect to the endpoint on the private address returned by the discovery SPI.
static com.hazelcast.config.properties.PropertyDefinition	ENDPOINTS Comma separated list of target cluster members, e.g.
static com.hazelcast.config.properties.PropertyDefinition	EXECUTOR_THREAD_COUNT The number of threads that the WanBatchReplication executor will have.
static com.hazelcast.config.properties.PropertyDefinition	GROUP_PASSWORD Group password of target cluster.
static com.hazelcast.config.properties.PropertyDefinition	MAX_ENDPOINTS The maximum number of endpoints that WAN will connect to when using a discovery mechanism to define endpoints.
static com.hazelcast.config.properties.PropertyDefinition	RESPONSE_TIMEOUT_MILLIS Duration in milliseconds to define waiting time before retrying to send the events to target cluster again in case of acknowledgement is not arrived.
static com.hazelcast.config.properties.PropertyDefinition	SNAPSHOT_ENABLED This property is only valid when used with WanBatchReplication implementation.

Method Summary

Modifier and Type	Method and Description
static <T extends Comparable> T	getProperty(com.hazelcast.config.properties.PropertyDefinition propertyDefinition, Map<String,Comparable> propertyMap, T defaultValue)

Methods inherited from class java.lang.Object

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

Field Detail

BATCH_SIZE

public static final com.hazelcast.config.properties.PropertyDefinition BATCH_SIZE

Defines the maximum batch size that can be sent to target cluster. Valid when used with WanBatchReplication implementation.

BATCH_MAX_DELAY_MILLIS

public static final com.hazelcast.config.properties.PropertyDefinition BATCH_MAX_DELAY_MILLIS

Defines the maximum amount of time to be waited before sending a batch of events to target cluster, if BATCH_SIZE of events have not arrived within this duration.

SNAPSHOT_ENABLED

public static final com.hazelcast.config.properties.PropertyDefinition SNAPSHOT_ENABLED

This property is only valid when used with WanBatchReplication implementation. When enabled, only the latest WanReplicationEvent of a key is sent to target.

RESPONSE_TIMEOUT_MILLIS

public static final com.hazelcast.config.properties.PropertyDefinition RESPONSE_TIMEOUT_MILLIS

Duration in milliseconds to define waiting time before retrying to send the events to target cluster again in case of acknowledgement is not arrived.

ACK_TYPE

public static final com.hazelcast.config.properties.PropertyDefinition ACK_TYPE

Determines acknowledgement waiting type of WAN replication operation invocation.

See Also:

for valid values.

GROUP_PASSWORD

public static final com.hazelcast.config.properties.PropertyDefinition GROUP_PASSWORD

Group password of target cluster.

ENDPOINTS

public static final com.hazelcast.config.properties.PropertyDefinition ENDPOINTS

Comma separated list of target cluster members, e.g. 127.0.0.1:5701, 127.0.0.1:5702.

DISCOVERY_PERIOD

public static final com.hazelcast.config.properties.PropertyDefinition DISCOVERY_PERIOD

Period in seconds in which WAN tries to discover new endpoints and reestablish connections to failed endpoints. The default is 10 (seconds).

MAX_ENDPOINTS

public static final com.hazelcast.config.properties.PropertyDefinition MAX_ENDPOINTS

The maximum number of endpoints that WAN will connect to when using a discovery mechanism to define endpoints. Default is WanConfigurationContext.DEFAULT_MAX_ENDPOINTS. This property has no effect when static endpoint IPs are defined using the ENDPOINTS property.

EXECUTOR_THREAD_COUNT

public static final com.hazelcast.config.properties.PropertyDefinition EXECUTOR_THREAD_COUNT

The number of threads that the WanBatchReplication executor will have. The executor is used to send WAN events to the endpoints and ideally you want to have one thread per endpoint. If this property is omitted and you have specified the ENDPOINTS property, this will be the case. If, on the other hand, you are using WAN with the discovery SPI and you have not specified this property, the executor will be sized to the initial number of discovered endpoints. This can lead to performance issues if the number of endpoints changes in the future - either contention on a too small number of threads or wasted threads that will not be performing any work.

DISCOVERY_USE_ENDPOINT_PRIVATE_ADDRESS

public static final com.hazelcast.config.properties.PropertyDefinition DISCOVERY_USE_ENDPOINT_PRIVATE_ADDRESS

Determines whether the WAN connection manager should connect to the endpoint on the private address returned by the discovery SPI. By default this property is false which means the WAN connection manager will always use the public address.

See Also:

WanConnectionManager.discoverEndpointAddresses(), DiscoveryNode.getPublicAddress(), DiscoveryNode.getPrivateAddress()

Method Detail

getProperty

public static <T extends Comparable> T getProperty(com.hazelcast.config.properties.PropertyDefinition propertyDefinition,
                                                   Map<String,Comparable> propertyMap,
                                                   T defaultValue)